腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(4034)
视频
沙龙
2
回答
如何
使用
REST
API
触发
气流
dag
(
I
get
"
Property
is
read-only
- '
state
'",
error
)
python-3.x
、
rest
、
airflow
、
directed-acyclic-graphs
、
airflow-api
我正在尝试
使用
REST
API
触发
气流
dags。它不起作用。我得到一个错误400,响应如下: { "status": 400, "type": "htt
浏览 67
提问于2021-04-15
得票数 1
回答已采纳
2
回答
如何
触发
从Python脚本中运行的
气流
DAG
?
python
、
python-3.x
、
airflow
、
directed-acyclic-graphs
使用
apache
气流
,我创建了一些DAGS,其中有些不按计划运行。编辑??
浏览 5
提问于2020-02-04
得票数 9
回答已采纳
7
回答
基于Webrequest的
气流
作业运行
python
、
airflow
我想知道
气流
任务是否可以在HTTP上得到请求时执行。我对
气流
调度部分不感兴趣。我只想用它代替芹菜。 谢谢。
浏览 6
提问于2017-02-22
得票数 32
回答已采纳
2
回答
如何
获得在
气流
中运行的当前进程的所有任务及其状态的列表
python
、
airflow
、
directed-acyclic-graphs
需要帮助来提取所有任务的列表,以及当前状态成功/失败的当前进程运行。我有一个带有python操作符的任务,它在工作流的末尾执行。此任务的职责是返回与状态一起执行的任务的no。
浏览 10
提问于2022-06-22
得票数 0
回答已采纳
1
回答
如何
使用
气流
API
插件?
python-3.x
、
airflow
我想用这个 github列出并
触发
DAG
。我应该
如何
并将这个插件放在我的airflow文件夹中,以便我可以调用端点? 在airflow.cfg文件中有什么需要更改的吗?
浏览 1
提问于2020-03-03
得票数 0
1
回答
哪些
气流
权限允许
触发
通过
API
运行的
DAG
?
airflow
、
airflow-2.x
、
airflow-api
使用
气流
2.0.2,我试图
使用
气流
API
触发
DAG
运行。当我运行一个简单的我得到了预期的结果: "pools"null, "titl
浏览 18
提问于2021-12-13
得票数 0
2
回答
气流
:是否有可能将DagRun标记为失败/杀死它?
python
、
airflow
我想以编程方式杀死一个
dag
运行。我
如何
通过Python或其他方式来实现呢?
浏览 13
提问于2022-07-15
得票数 0
1
回答
如何
在
使用
气流
实现的工作流中等待
DAG
任务中的异步事件?
airflow
、
apache-airflow
我
使用
气流
实现的工作流包含任务A、B、C和D。我希望工作流在任务C处等待事件。在
气流
传感器中,通过轮询某种状态来检查某些条件,如果该条件为真,则会
触发
工作流中的下一个任务。我的要求是避免投票。一个答案提到了一个
气流
的,它创建了一个
rest
_
api
端点来
触发
气流
CLI --
使用
这个插件,我可以在工作流中
触发
一个任务。但是,在我的工作流中,我希望实现一个任务,该任务在没有轮询的情况下等待
rest
浏览 0
提问于2017-11-23
得票数 16
4
回答
是否可以在
气流
中将用户输入从
dag
传递到子
dag
?
python
、
airflow
我试图在基于用户输入的
气流
中生成动态工作流。我知道可以选择基于文件和数据库的数据,但在所有这些情况下,工作流将不直接依赖用户输入,如果多个用户正在
使用
相同的数据,那么在这种情况下也可能会出现问题。
浏览 3
提问于2020-11-30
得票数 3
回答已采纳
1
回答
如何
使用
过去的数据间隔日期启动
气流
Dag
python
、
airflow
、
directed-acyclic-graphs
、
gcs
我在Ariflow 2.2.3中工作,我不知道
如何
用过去的执行日期
触发
我的进程。当我
使用
Config单击
触发
器
dag
时,我将日历更改为我想要的日期,但当我单击run时,我看到了运行,但它没有运行。你知道
如何
用过去的约会来
触发
一个达格吗?
浏览 9
提问于2022-11-21
得票数 0
1
回答
基于RabbitMQ消息代理的
气流
分布式消息流
python
、
airflow
、
airflow-scheduler
我是阿帕奇
气流
的初学者。我需要根据JSON负载来调度任务。简单地说,JSON有效负载包含日期和时间以及调度任务所需的数据。我可以
使用
Apache
气流
来满足这一要求吗?与上面的图表一样,我希望
触发
带有JSON有效负载的
DAG
,并根据有效负载中的日期和时间对RabbitMQ broker上的数据进行调度。因此,在worker节点内部,可以
使用
Python操作符来调用后端。 我现在走的是这条路吗?根据我的理解,CeleryExecutor.会自动处理RabbitMQ和worker节点部件。我可
浏览 7
提问于2021-06-20
得票数 1
1
回答
如何
获得存储在
DAG
文件夹中的python脚本中运行的composer
气流
的
DAG
列表?
google-cloud-platform
、
airflow
、
airflow-scheduler
、
google-cloud-composer
现在,我面临的挑战是
如何
在python脚本中获得运行
DAG
的列表,并从本地系统
触发
单个
DAG
。在我的本地,我设置了私有SSH键,所以我可以
使用
下面的命令获得在composer
气流
中运行的
DAG
列表。/
GET
请求,但是当我
触发
它时会面临身份验证错误。curl -X POST http://<airflow servername>
api
/experimental
浏览 2
提问于2019-12-18
得票数 0
回答已采纳
1
回答
如何
在
气流
中向Python程序提交参数?
python
、
airflow
我们有一个前端服务器,它直接
使用
dag
执行dags (DagBag(),
get
_
dag
(),然后是
dag
_run())。Dags运行良好,问题是,我们无法找到一种
使用
特定参数来执行此类dags的方法。最接近的解决方案是
使用
变量
API
,它
使用
set()和
get
()方法,但是这些变量是全局的,在
使用
相同变量名的并发操作时可能存在冲突。 我们
如何
运行一个
dag
并设置可用
浏览 4
提问于2017-07-14
得票数 0
1
回答
气流
-
如何
使用
REST
的安全授权
rest
、
authentication
、
post
、
airflow
简介:POST: http://{{url}}:{{port}}/
api
/experimental/dags/MY_
DAG
_ID/
dag
_runs 'Content-Type': 'application/
浏览 3
提问于2020-03-18
得票数 5
回答已采纳
1
回答
云编写器非交互式身份验证
flask
、
google-cloud-platform
、
airflow
、
google-cloud-composer
我已经构建了一个
气流
插件来从composer风流环境中获取数据,并且访问云编写器的工作非常好,因为它需要用户在访问任何
气流
端点之前登录。 '
state
':
dag
_run.
get
_
state
(), 'start_date': (None if not
dag</em
浏览 1
提问于2018-09-10
得票数 0
2
回答
如何
获取
dag
状态,如正在运行、成功或失败
python-2.7
、
airflow
我想知道
dag
的状态是运行、失败还是成功。我正在通过CL参数airflow trigger
触发
dag
,在作业执行之后,我想知道运行的状态。我找不到任何方法。我尝试了airflow
dag
_
state
,但它没有提供任何帮助。如果一天中有不止一次运行,通过命令行参数或python代码获取最近一次运行的状态,我应该怎么做?
浏览 35
提问于2019-11-07
得票数 3
回答已采纳
2
回答
气流
API
有效载荷作为python脚本的输入
python-3.x
、
airflow
、
directed-acyclic-graphs
我正在
使用
以下python脚本
触发
一个
气流
DAG
:
API
调用:import json from airflow.utils.dates import days_ago
dag
_run = kwargs.
g
浏览 1
提问于2021-07-28
得票数 2
回答已采纳
2
回答
触发
循环中的
DAG
airflow-scheduler
、
airflow
我试图
触发
3次
DAG
任务,
如何
使用
python脚本来完成这一任务。目前我的流动工作是 BashOperator( task_id='task1',bash_command='ssh“runJob.
浏览 0
提问于2021-02-12
得票数 0
1
回答
如果之前的任务执行时间较长,则会跳过
气流
计划
airflow
、
airflow-scheduler
我在我的
气流
DAG
中有两个任务。一个
触发
API
调用( Http操作符),另一个
使用
另一个
api
( Http传感器)不断检查其状态。此
DAG
计划每小时& 10分钟运行一次。/airflow_home;export AIRFLOW_CONN_
REST
_
API
= '
浏览 11
提问于2019-08-09
得票数 1
回答已采纳
1
回答
如何
检索Python中所有
气流
DAG
的列表?
python
、
command-line-interface
、
airflow
有一个CLI函数airflow dags list,它列出了当前环境中的所有
DAG
。Python中有类似的函数吗?
浏览 14
提问于2022-04-20
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
REST API 设计与开发最佳实践
DRF 框架总结-引入 Django REST framework 框架
深入理解什么是RESTful API?
REST API 设计与开发实践
基于Swagger实现RESTful指南
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券