以编程方式设置气流中的连接/变量

Question

有没有办法在气流中以编程方式设置连接/变量？我知道这违背了不在代码中公开这些细节的真正目的，但是如果我可以执行类似以下伪代码的操作，调试它真的对我有很大帮助：

# pseudo code
from airflow import connections
connections.add({name:'...',
                 user:'...'})

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
) 
session = settings.Session() 
session.add(conn)
session.commit()

至于变量 - 只需使用 API。请参阅下面的示例

from airflow.models import Variable
Variable.set("my_key", "my_value")

可以找到关于此主题的好博客 post here。

以编程方式设置气流中的连接/变量

programatically set connections / variables in airflow

python

airflow