Airflow Variables 参数化

Variables 存全局配置类小值（阈值、开关、地址），运行时用 Variable.get 读取；高频读取会打元数据库，推荐模板引用方式或在执行器侧缓存。

写入	界面 / CLI / API / 环境变量 AIRFLOW_VAR_X
读取	Variable.get(key, deserialize_json=True)
模板引用	{{ var.value.key }}
适用	阈值、开关、小段配置

CLI 设置变量

airflow variables set batch_size 500
airflow variables set alert_webhook 'https://ops.example.com/hook'

from airflow.models import Variable
batch_size = int(Variable.get("batch_size", default_var="500"))
where = "{{ var.value.dw_start_date }}"

在每个任务的执行函数里调用 Variable.get 会造成大量元数据库查询，尽量在模板里引用或缓存。

‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌