通过管理员 – >连接,我们有能力创建/修改连接的参数,但我想知道我是否可以通过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.