airflow - 如何在 Airflow 中打印变量的值

Question

我正在尝试打印在 Airflow dag 中计算的变量的内容，因此我在 bash 运算符中使用了 echo，但它不起作用
我尝试使用预定义变量，但是得到了相同的输出
这是一个例子:

with DAG(
    dag_id="tmp",
) as dag:
test="test"
test_dag = BashOperator(
    task_id="test_dag",
    bash_command='echo $test',
)

输出始终为空:

Output:
INFO -

Answer 1

您可以在 f 字符串中传递变量。您甚至可以根据变量设置task_id。请参阅:

    with DAG(
        dag_id="tmp",
    ) as dag:
        test="test"
        test_dag = BashOperator(
            task_id=f"t1_{test}",
            bash_command=f"echo {test}",
        )