【问题标题】: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】:

    这是我会尝试的:

    1. Conn 类型:mongodb+srv(或mongodb
    2. 主持人:my-cluster.blahlah.mongodb.net,
    3. 登录:<username>,密码:<password>
    4. 架构:管理员(或您的 authDB)
    5. JSON 对象就是这么简单
    { retryWrite:true, 
      <field>:value, 
      w:majority
    }
    

    【讨论】:

    • 也许架构是数据库名称?
    • 仍然没有运气。在我在password字段中输入任何值并单击保存后,然后返回连接,password字段每次都设置为空...
    • menu-&gt;admin-&gt;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}

    【讨论】:

      猜你喜欢
      • 2022-11-21
      • 2022-08-16
      • 2020-09-27
      • 2021-10-19
      • 2018-01-09
      • 2020-07-11
      • 2020-07-05
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多