如何解决如何访问下游的气流渲染模板?
气流版本:1.10.12
我在传递渲染模板对象以供下游使用时遇到问题。我正在尝试从 Airflow conf 中获取两个配置变量。
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime
with DAG(
dag_id="example_trigger_target_dag",default_args={"owner": "airflow"},start_date=datetime(2021,6,24),schedule_interval='@once',tags=['example'],) as dag:
bash_task = BashOperator(
task_id="bash_task",bash_command='echo "{{ conf.test }}:{{ conf.tag }}"',xcom_push=True
)
基本上它传递给 xcom 的只是 :
不存在变量。但是,完整呈现的字符串确实显示在 rendered
选项卡中。我错过了什么吗?
编辑:变量存在于 conf 中,出于安全原因,我只是将它们替换为 test
和 tag
。
解决方法
我刚刚测试了这段代码(我使用的是 Airflow 2.1.0)并得到了结果。
BashOperator(task_id='test_task',bash_command='echo " VARS: {{ conf.email.email_backend '
'}}:{{ conf.core.executor }}"',do_xcom_push=True)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。