Airflow -如何访问非模板化字段中的执行参数？

Airflow 是一个开源的工作流编排和调度平台，用于创建、调度和监控工作流。它以有向无环图 (DAG) 的形式定义任务和任务之间的依赖关系，允许用户以可靠和可扩展的方式编排和执行任务。

在 Airflow 中，可以通过使用 Jinja 模板语法来访问执行参数中的非模板化字段。Jinja 模板语法允许在字符串中插入变量或表达式，以便在任务执行期间动态计算。

要访问非模板化字段中的执行参数，可以使用 params 属性。在 DAG 的任务定义中，可以通过 dag_run.conf 访问传递给 DAG 运行的参数。这些参数可以在任务的 bash_command、python_callable 等属性中使用 Jinja 模板语法进行访问。

以下是一个示例任务定义，展示如何使用 Jinja 模板语法访问执行参数中的非模板化字段：

from airflow import DAG
from airflow.operators.bash_operator import BashOperator

default_args = {
    'start_date': datetime(2022, 1, 1),
}

with DAG('example_dag', default_args=default_args) as dag:
    task = BashOperator(
        task_id='example_task',
        bash_command='echo {{ params.message }}',
        params={'message': 'Hello, Airflow!'},
    )

在上述示例中，任务的 bash_command 属性使用 Jinja 模板语法将 params.message 插入到命令中。在任务执行期间，params.message 会被替换为 'Hello, Airflow!'，最终执行的命令为 echo Hello, Airflow!。

关于 Airflow 的更多信息和使用方法，可以参考腾讯云的产品文档：Airflow 产品介绍。