'How to connect to Mongodb in Apache Airflow?

I am trying to process data from external source and store it in my MongoDB. So I am trying to understand how should I access Mongodb Hook in my operator.

mongodbairflow


Solution 1:[1]

Here is an official example for how to use mongo hook from an operator:

https://github.com/airflow-plugins/mongo_plugin/blob/master/operators/s3_to_mongo_operator.py

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source
Solution 1 aysegulpekel

Related Questions