我可以在气流中提及多少个与 mongo 的连接？

Question

我的气流 mongo_default 和 mongo_test 中有两个 mongo 连接。

我想使用 mongo 测试，但它以某种方式进入 mongo_default，我不明白为什么：

hook = MongoHook(mongo_conn_id='mongo_test')

我收到错误：连接到 MongoDB 时出错：[Errno -2] 名称或服务未知

有人可以帮我吗。

Answer 1

根据

airflow.providers.mongo.hooks.mongo.MongoHook

文档，您应该使用

conn_id

参数，并且

mongo_conn_id

没有任何影响。

hook = MongoHook(conn_id='mongo_test')