我正在尝试处理来自外部来源的数据,并将其存储在我的MongoDB中。因此,我正在尝试了解应该如何在我的操作员中访问MongoDB Hook。
2jcobegt1#
下面是一个官方示例,说明如何从操作符使用mongo钩子:https://github.com/airflow-plugins/mongo_plugin/blob/master/operators/s3_to_mongo_operator.py
1条答案
按热度按时间2jcobegt1#
下面是一个官方示例,说明如何从操作符使用mongo钩子:
https://github.com/airflow-plugins/mongo_plugin/blob/master/operators/s3_to_mongo_operator.py