是否有方法通过Airflow API创建/修改连接

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

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.

airflow connections --add ...

用法:

airflow connections [-h] [-l] [-a] [-d] [--conn_id CONN_ID]
                    [--conn_uri CONN_URI] [--conn_extra CONN_EXTRA]
                    [--conn_type CONN_TYPE] [--conn_host CONN_HOST]
                    [--conn_login CONN_LOGIN] [--conn_password CONN_PASSWORD]
                    [--conn_schema CONN_SCHEMA] [--conn_port CONN_PORT]

https://airflow.apache.org/cli.html#connections

它看起来不像CLI目前支持修改现有的连接,但是在GITHUB上有一个JRRA问题,它带有一个活动的开放式PR。

• AIRFLOW-2840 - cli option to update existing connection
• https://github.com/apache/incubator-airflow/pull/3684