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

Question

通过Admin -> Connections，我们可以创建/修改连接的参数，但是我想知道是否可以通过API进行相同的操作，以便可以以编程方式设置连接

airflow.models.Connection似乎它只处理实际连接到实例，而不是将其保存到列表中。似乎应该已经实现了一个功能，但是我不确定在哪里可以找到该特定功能的文档。

Answer 1

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

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.