连接实际上是一个模型,可以用来查询和插入新连接
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.



