使用 Airflow 设置 MongoDB 连接答案

【问题标题】：Setting MongoDB connection with Airflow使用 Airflow 设置 MongoDB 连接
【发布时间】：2021-02-28 02:04:42
【问题描述】：

根据天文学家文档here：

尽管如此，我仍然不太确定如何为此在 Extras 中构建 JSON。我试过了： { uri: mongodb+srv://myuser:mypass@my-cluster.dwxnd.gcp.mongodb.net/mydb?retryWrites=true&w=majority } 在 Extras 中，但这不起作用：

这似乎应该是显而易见的，但我正在努力。使用 MongoDB Atlas 中的 MongoDB URI 在 Airflow 中创建此连接的正确方法是什么？

【问题讨论】：

标签： mongodb database-connection airflow

【解决方案1】：

这是我会尝试的：

Conn 类型：mongodb+srv（或mongodb）
主持人：my-cluster.blahlah.mongodb.net,
登录：<username>，密码：<password>。
架构：管理员（或您的 authDB）
JSON 对象就是这么简单

{ retryWrite:true, 
  <field>:value, 
  w:majority
}

【讨论】：

也许架构是数据库名称？
仍然没有运气。在我在password字段中输入任何值并单击保存后，然后返回连接，password字段每次都设置为空...
menu->admin->connections 是我输入所有这些信息的地方。使用 mongo_conn_id 作为连接 ID 名称。
我想我明白了，一旦我 100% 确定会发布解决方案
我能想到的最后一件事是 MongoDB 被 mongodb+srv 取代，但找不到其他任何东西。

【解决方案2】：

此设置在 MongoDB Atlas 中对我有用。 Extra 部分很重要，因为它将mongodb+srv 添加到最终连接URI。确保您已安装提供程序包 (http://airflow.apache.org/docs/apache-airflow-providers-mongo/stable/index.html)。

Conn ID：mongo_connection
连接类型：MongoDB
主持人：cluster0.mtfak.mongodb.net
架构：MyDatabaseName
登录：myuser
密码：mypass
端口：空
额外：{"srv": true}

【讨论】：