mongodb - 使用 Airflow 设置 MongoDB 连接
问题描述
根据天文学家这里的文档:
尽管如此,我仍然不太确定如何为此在 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+srv
或mongodb
) - 主持人:
my-cluster.blahlah.mongodb.net
, - 登录名:
<username>
,密码:<password>
。 - 架构:管理员(或您的 authDB)
- JSON对象就是这么简单
{ retryWrite:true,
<field>:value,
w:majority
}
推荐阅读
- php - 仅为特定的重力形式运行函数
- java - 使用 ddl-auto 从 PostreSQL 获取图像时,@Transactional 不起作用:更新
- linux - NGINX 读取文件夹中新文件的自动权限
- flask - 烧瓶类型错误:“NoneType”不可下标
- python - Python 3.8:为什么即使 if 语句为 false,new_list 也会被更新?
- python - 如何在 pandas groupby 操作中计算 lambda 函数并同时添加一个 size 列?
- django - 找不到 Django 管理员和 wagtail 静态文件
- tensorboard - 如何在张量板上跟踪训练有素的张量流对象检测 api 的准确性
- typescript - Typescript如何检查具有多种类型的对象的类型
- python - UDP客户端错误:ConnectionResetError:[WinError 10054]一个现有的连接被远程主机强行关闭