Как подключиться к Mongodb в Apache Airflow?

Question

Я пытаюсь обработать данные из внешнего источника и сохранить их в моем MongoDB. Поэтому я пытаюсь понять, как мне получить доступ к Mongodb Hook в моем операторе.

Answer 1

Вот официальный пример того, как использовать монго-хук от оператора:

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