我正在尝试处理来自外部源的数据并将其存储在我的 MongoDB 中。所以我试图了解如何在运算符(operator)中访问 Mongodb Hook。
最佳答案
这是一个关于如何使用运算符(operator)的 mongo hook 的官方示例:
https://github.com/airflow-plugins/mongo_plugin/blob/master/operators/s3_to_mongo_operator.py
关于mongodb - 如何在 Apache Airflow 中连接到 Mongodb？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54244511/
相关文章：
ruby-on-rails - 如何运行 GenieACS？
mongodb - 如何在 goLang 中的整个应用程序中将 MongoDB session 作为全局变量维护
mongodb 的MongoWaitQueueFullException
javascript - 如何按类型为 bundle 的 itemId 总和数量和类型为 sale_order javascript 的 parentId 进行分组？
python - Airflow XCOM KeyError : 'task_instance'
node.js - 如何在 Mongoose Schema 中存储 URL 值？
ubuntu - WSL : PermissionError: [Errno 1] Operation not permitted: 中的 Airflow 网络服务器错误
Airflow 实验 REST API FORBIDDEN 403 响应