有没有一种方法可以通过Airflow API创建修改连接

有没有一种方法可以通过Airflow API创建修改连接,第1张

有没有一种方法可以通过Airflow API创建/修改连接

连接实际上是一个模型,可以用来查询和插入新连接

from airflow import settingsfrom airflow.models import Connectionconn = Connection(        conn_id=conn_id,        conn_type=conn_type,        host=host,        login=login,        password=password,        port=port) #create a connection objectsession = settings.Session() # get the sessionsession.add(conn)session.commit() # it will insert the connection object programmatically.


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5647135.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存