如何Injectairflowvariableintotasks？

在Airflow中，可以使用变量（variable）来传递配置、密码等信息。要在任务中使用Airflow变量，可以使用 jinja2 模板语言。

具体步骤如下：

1. 在 Airflow 的Web界面中，打开Admin -> Variables页面，可以创建、修改、删除变量。如下图所示：

2. 在DAG文件中，可以使用 jinja2 模板引擎，通过{{ var.value.<variable_name> }}访问变量来注入变量值。例如：

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2021, 1, 1),
    'email': ['airflow@example.com'],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

dag = DAG('example_dag', default_args=default_args, schedule_interval=timedelta(days=1))

task1 = BashOperator(
    task_id='task1',
    bash_command='echo {{ var.value.example_variable }}',
    dag=dag
)

# 运行任务之前需要在 Airflow 的Web界面中创建example_variable变量并设置它的值

在 Airflow 的Web界面中，创建名为 example_variable 的变量，并设置它的值为“Hello Airflow”：

3. 可以运行DAG，查看任务的日志输出：

从日志输出中可以看到，任务执行时输出了变量的值。这样就实现了在任务中注入Airflow变量的功能。