Airflow

Question

我有一个 Airflow 变量

我想在 Bash 运算符的 bash 命令中获取它。

我试过了：

t2 = BashOperator(
        task_id= 'try_bash',
        bash_command="echo {{var.aa}}",
        dag=dag 

and

t2 = BashOperator(
        task_id= 'try_bash',
        bash_command=" echo {{var.value.aa}}",
        dag=dag

我知道要获取变量我可以做到

Variable.get("aa")

但我想直接在bash命令中获取它。

可能吗？

谢谢

Answer 1

这应该有效。与您最初拥有的略有不同：

t2 = BashOperator(
    task_id= 'try_bash',
    bash_command='echo "{{ var.value.aa }}"',
    dag=dag,
)

Airflow - 如何在 Bash 运算符的 bash 命令中获取 Airflow 变量？

Airflow - How to get an Airflow variable inside the bash command in Bash Operator?

bash