先将Airflow和变量import进Python文件中:
from airflow.models import Variable
即可通过Variable.get方法获取变量:
my_var = Variable.get("my_variable")
先将Airflow、连接(Connection)和密钥(Hook)import进Python文件中:
from airflow.models import Connection
from airflow.hooks.base_hook import BaseHook
通过Connection对象获取密钥的值:
conn = Connection.get_connection_from_secrets('my_connection_id')
my_secret = BaseHook.get_connection(conn.conn_id).password