python - 有没有办法通过 Airflow API 创建/修改连接
问题描述
通过Admin -> Connections
,我们有能力创建/修改连接的参数,但我想知道我是否可以通过 API 做同样的事情,所以我可以以编程方式设置连接
airflow.models.Connection
似乎它只处理实际连接到实例而不是将其保存到列表中。这似乎是一个应该实现的功能,但我不确定在哪里可以找到这个特定功能的文档。
解决方案
Connection 实际上是一个模型,您可以使用它来查询和插入新连接
from airflow import settings
from airflow.models import Connection
conn = Connection(
conn_id=conn_id,
conn_type=conn_type,
host=host,
login=login,
password=password,
port=port
) #create a connection object
session = settings.Session() # get the session
session.add(conn)
session.commit() # it will insert the connection object programmatically.
推荐阅读
- python - 有没有办法使用这个函数在熊猫数据帧上使用多处理
- node.js - 节点:package.json 应该在 src 文件夹中还是在父文件夹中?
- version - GIMP如何保存旧版本的xcf文件格式
- google-cloud-platform - 如何使用带有替换的 Google Cloud Build 部署 Google Cloud 函数
- html - 始终停止在页脚上方滚动返回到顶部按钮纯 css 和 html
- node.js - 无法使用 lambda 函数写入 SQS 队列
- android - 无法删除(白俄罗斯语)语言的每个字符后的空格
- angular - Angular 5 到 6 没有向后兼容的 RxJS (rxjs-compat)
- eclipse - 如何在 Ec 中调整 Package Explorer 中项目的位置
- sql-server - 如何在不使用 while 循环或递归的情况下实现并发?