腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Airflow
中
传递
嵌套
jinja
模板
内
的
变量
bash
、
environment-variables
、
jinja2
、
airflow
我创建了一个
变量
(从
Airflow
UI): Key: env_variables Value: {'xx': 'yy`} 并尝试使用var.json.env_variables.xx内部bash操作符进行访问但是"xx“
的
值是动态
的
,我是从REST API
传递
的
,并使用dag_run.conf['param']访问它(dag_run.conf['param']应该返回xx)。如何在
Airflow</
浏览 58
提问于2021-09-23
得票数 0
回答已采纳
1
回答
使用
Airflow
MySQL Operator运行MySQL脚本时出现问题
airflow
我不理解
在
Apache
Airflow
中使用MySQL操作符调用和MySQL脚本。 当我运行这个任务
的
时候...= True, ) 我
在
回溯
中
得到这个错误...
jinja
2.exceptions.TemplateNotFound: /home/user/DBScr
浏览 56
提问于2020-01-26
得票数 0
回答已采纳
1
回答
Jinja
模板
中
的
嵌套
打印语句
python
、
flask
、
jinja2
我正在使用
Jinja
2
模板
创建一个链接,我遇到了一个问题。我想访问一个
在
代码块
中
传递
给
模板
的
变量
,但是我不知道该如何做,甚至可能。我想做
的
是:因此,基本上,我希望使用
模板
中
的
url_for
浏览 4
提问于2013-12-30
得票数 6
回答已采纳
1
回答
Airflow
-无法对Kubernetes Pod操作员任务
中
的
资源使用
jinja
模板
jinja2
、
airflow
、
kubernetespodoperator
Airflow
-无法对Kubernetes Pod操作员任务
中
的
资源使用
jinja
模板
。能够为环境
变量
、图像使用
jinja
模板
,但不能为资源指定CPU和内存(请求和限制)。
浏览 31
提问于2021-11-29
得票数 1
2
回答
气流宏可以与CloudSqlInstanceExportOperator一起使用吗?
airflow
我们使用气流来调度每日
的
数据库导出使用。这似乎不适用于气流宏。我们试图使用where子句中
的
执行日期宏或{{ ds }}导出1天数据。使用宏非常重要,因为我们希望我们
的
DAG能够回填。AND "{{ ds }} 23:59:59 } } task
浏览 11
提问于2020-12-16
得票数 1
回答已采纳
1
回答
在
Jinja
2
模板
中
默认过滤器中使用
变量
ansible
在
一个Ansible
Jinja
2
模板
中
,我试图设置一个“缺省”值,其中也包含一个
变量
,但是它打印
的
是文字,而不是插值。hostvars[inventory_hostname]['instances'][app_instance]['homedir'] | default("/home/{{ app_instance }}/
airflow
") }}
airflow<
浏览 2
提问于2018-06-11
得票数 7
回答已采纳
1
回答
如何在python函数中使用
airflow
jinja
模板
?
python
、
airflow
有没有一种方法可以
在
python函数(Print_hello)
中
应用
jinja
模板
,而不使用
airflow
变量
(位于
airflow
web UI
中
)或全局
变量
?
浏览 16
提问于2021-01-12
得票数 1
回答已采纳
1
回答
Airflow
XCom到Python
变量
google-app-engine
、
google-cloud-platform
、
google-bigquery
、
google-cloud-storage
、
airflow
我有一个存储
的
Python expense_list,我希望将其转换为Python
变量
expense_variable (而不是将其
传递
到
模板
化字段
中
)。我尝试
在
我
的
DAG
中
设置
变量
,但以下代码不起作用。expense_variable = "{{task_instance.xcom_pull(task_ids='expense_list')}}" 如何在
Airflow
中将存储
浏览 0
提问于2019-09-16
得票数 1
2
回答
如何在气流
变量
上强制执行
Jinja
模板
?
airflow
说:You can use
Jinja
templating with every parameter that is marked as “templated” in the documentation气流自动
模板
化气流世界
中
的
特定参数(例如PythonOperator
的
某些参数)是有意义
的
。我想知道最好
的
/正确
的
方法是让一个非气流
变量
模板
化。我
的
具体用例类似于: from
ai
浏览 1
提问于2018-03-28
得票数 5
4
回答
将命令行参数
传递
给
airflow
BashOperator
python
、
bash
、
workflow
、
airflow
有没有办法将命令行参数
传递
给
Airflow
BashOperator。目前,我有一个python脚本,它接受日期参数并执行一些特定
的
活动,比如清理比给定日期旧
的
特定文件夹。
在
只有一个任务
的
简化代码
中
,我想要做
的
是from
airflow
.operators import BashOperatorfrom
airflow
.models imp
浏览 5
提问于2017-02-03
得票数 10
1
回答
保存解析json文件
的
输出并将其
传递
给Bigqueryinsertjoboperator
google-bigquery
、
airflow
、
google-cloud-composer
我需要一些建议来解决这个审计目的
的
要求。我正在使用
airflow
composer - dataflow java操作员作业,它在作业完成后输出带有状态和错误消息详细信息
的
json文件(放入
airflow
数据文件夹)。我想通过一些运算符从json文件中提取状态和错误信息,然后将
变量
传递
给下一个流水线作业Bigqueryinsertjoboperator,它调用存储
的
proc,并将状态和错误信息作为输入参数
传递
,最后写入
浏览 16
提问于2021-08-31
得票数 0
1
回答
Airflow
Jinja
模板
python
、
jinja2
、
airflow
尝试
在
Airflow
中使用
Jinja
模板
引用Python
中
的
变量
以打印
变量
值 job_id = 15 print("{{ params.job_id }}") 但是,它正在打印: {{ params.job_id}} 我应该如何触发正确
的
渲染?
浏览 31
提问于2020-10-07
得票数 0
1
回答
Airflow
:将{{ params.hotel_ids }}作为参数
传递
给PostgresOperator
airflow-scheduler
、
airflow
我们可以
在
气流后置参数
中
传递
数组列表吗?我
在
尝试像这样
的
东西
在
“s3_to_redshift.sql”
中
。下面是我
的
运算符: task_id='s3_to_redshift', postgres_co
浏览 4
提问于2020-02-12
得票数 0
1
回答
Airflow
: PythonOperator:为什么要包含'ds‘arg?
airflow
在
定义一个稍后要用作python_callable
的
函数时,为什么要将'ds‘包含为该函数
的
第一个参数?例如: pass 我查看了
Airflow
文档,但找不到任何解释。
浏览 0
提问于2016-11-11
得票数 20
回答已采纳
1
回答
Airflow
:如何实现动态html_content
airflow
我需要实现自定义电子邮件操作员
的
html_content动态,因为我们有不同
的
工作不同
的
html_content。另外,我需要值是动态
的
,例如,rows和filename 下面的示例是其中一个电子邮件正文: The `filename` has been delivered.
浏览 26
提问于2020-06-16
得票数 0
回答已采纳
2
回答
如何将Xcom
中
的
值
传递
给另一个运算符?
airflow
DockerOperator有一个参数xcom_push,设置该参数时,会将Docker容器
的
输出推送到Xcom: xcom_push=True, xcom_all=True,
在
Xcom下
的
管理界面
中
,我可以使用键return_value看到这些值
浏览 3
提问于2019-11-20
得票数 2
1
回答
从UI手动运行
传递
配置
的
Airflow
kubernetes
、
airflow
有没有办法从手动
的
DAG运行
中
传递
JSON配置(从dag_run.conf['attribute']到KubernetesPodOperator?尝试
在
YAML
中
的
模板
字段上使用
Jinja
模板
,但得到错误dag_run is not defined。namespace=NAMESPACE,
浏览 8
提问于2021-06-22
得票数 0
回答已采纳
1
回答
无法
在
PostgresOperator中使用
Jinja
模板
作为sql脚本
的
文件名
python
、
postgresql
、
bash
、
airflow
、
postgres-operator
一直
在
寻找这个问题,但所有的答案都是旧
的
,与我
的
问题无关。我试图将sql参数作为
Jinja
模板
传递
,但无法
传递
。我对气流有点陌生,这是代码,我不确定
Jinja
模板
是否
在
PostgresOperator
中
工作。如果有任何其他方法可以
传递
,请告诉我,再次我不是试图
在
SQL查询或文件
中
传递
jinja
模板</e
浏览 8
提问于2022-10-15
得票数 0
1
回答
execution_date
jinja
解析为字符串
airflow
我有一个气流守护程序,它使用以下
jinja
模板
:"{{ execution_date.astimezone('Etc/GMT+6').subtract(days=1).strftime('%Y-%m-%dT00:00:00') }}"TypeError:
浏览 1
提问于2019-07-09
得票数 0
1
回答
根据
airflow
中
sql查询
的
结果创建动态任务
airflow
、
pipeline
、
orchestration
、
airflow-2.x
我正在尝试用TaskGroup创建动态任务,并将结果保存在一个
变量
中
。该
变量
每N分钟修改一次,具体取决于数据库查询,但当第二次修改该
变量
时,调度程序就会崩溃 基本上,我需要根据查询
中
收到
的
唯一行
的
数量来创建任务。
浏览 23
提问于2021-03-15
得票数 4
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Python Flask JinJa2 语法介绍与示例讲解
Golang Template 简明笔记
Flask 入门系列教程02-模板
Python实现网页截屏、查库,并发每周定时发送邮件给你
补充谈谈Flask 的Jinja2
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券