MongoHook

Mongo

Interact with Mongo. This hook uses the Mongo conn_id. PyMongo Wrapper to Interact With Mongo Database Mongo Connection Documentation https://docs.mongodb.com/manual/reference/connection-string/index.html You can specify connection string options in extra field of your connection https://docs.mongodb.com/manual/reference/connection-string/index.html#connection-string-options

View on GitHub

Last Updated: Jan. 6, 2023

Access Instructions

Install the Mongo provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

mongo_conn_idThe Mongo connection id to use when connecting to MongoDB.

Documentation

Interact with Mongo. This hook uses the Mongo conn_id. PyMongo Wrapper to Interact With Mongo Database Mongo Connection Documentation https://docs.mongodb.com/manual/reference/connection-string/index.html You can specify connection string options in extra field of your connection https://docs.mongodb.com/manual/reference/connection-string/index.html#connection-string-options

If you want use DNS seedlist, set srv to True.

param mongo_conn_id

The Mongo connection id to use when connecting to MongoDB.

Was this page helpful?