是否可以在消息到达SQS队列时安排DAG运行？我还需要dag来处理队列中的消息。据我所知，这可以通过使用SQSSensor来完成，但我找不到任何示例，我对如何前进感到困惑。
浏览 24提问于2021-08-02得票数 0
我们正在新旧气流之间进行迁移，我们试图实现从Airflow1到Airflow2的触发器(反之亦然)，这有可能吗？
浏览 3提问于2022-02-07得票数 0
回答已采纳
4回答
基本上，我已经为任务准备好了脚本和dag，但该任务不会定期运行。相反，它需要在随机时间激活。(外部方会告诉我们是时候了，我们将运行它。在接下来的几个月里，这种情况可能会发生很多次。)有没有手动触发dag的方法？也欢迎任何其他方向/建议。谢谢。
浏览 3提问于2019-12-13得票数 6
我在我的气流DAG中有两个任务。一个触发API调用( Http操作符)，另一个使用另一个api ( Http传感器)不断检查其状态。此DAG计划每小时& 10分钟运行一次。我正在使用本地executor。我正在使用下面的脚本运行airflow服务器和调度程序。start_server.shexport <em
浏览 11提问于2019-08-09得票数 1
回答已采纳
我正在尝试使用AirFlow rest API触发我的dag。但是，不能理解如何进行身份验证。 下面的URL在我的浏览器中运行良好。http://localhost:8181/api/experimental/dags/demo/dag_runs 但是，下面的代码会给出身份验证错误。import requestsfrom pprint im
浏览 24提问于2020-04-21得票数 2
我想知道dag的状态是运行、失败还是成功。我正在通过CL参数airflow trigger触发dag，在作业执行之后，我想知道运行的状态。我找不到任何方法。我尝试了airflow dag_state，但它没有提供任何帮助。如果一天中有不止一次运行，通过命令行参数或python代码获取最近一次运行的状态，我应该怎么做？
浏览 35提问于2019-11-07得票数 3
回答已采纳
我有一个正在运行的dag，我可以使用REST API停止它吗？有一种方法可以删除正在运行的dag：https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#operation/delete_dag_run。但是没有REST
浏览 145提问于2021-10-09得票数 1
回答已采纳
我遇到了一个问题，我可以从airflow的rest api命令(https://airflow.apache.org/api.html)成功触发dag；但是，dag实例不能运行。我正在调用-> POST /api/experimental/dags/dag_id/dag_runs，其中dag_id
浏览 17提问于2019-10-03得票数 0
回答已采纳
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下删除按钮)
浏览 3提问于2020-06-11得票数 0
从When服务器触发DAG并转到图形视图时，运行id如下所示： ? 我可以在命令行中使用'airflow trigger_dag‘并指定'run_id’来指定此名称，但我不知道如何在通过when服务器触发DAG时指定此ID？ 有没有人找到了这样做的方法？
浏览 84提问于2021-04-26得票数 2
1回答
简介：POST: http://{{url}}:{{port}}/api/experimental/dags/MY_DAG_ID/dag_runs 'Content-Type': 'application/json
浏览 3提问于2020-03-18得票数 5
回答已采纳
现在我想解析这些文件从s3桶，并加载到MySQL数据库使用Apache Airflow。通过阅读这里的几篇文章：和，我认为最好使用AWS lambda触发我的Airflow DAG，一旦文件到达s3文件夹，它就会被调用。作为Airflow和Lambda的新手，我不知道如何设置lambda来触发气流DAG。在这方面，如果有人能给出一些建议，那将是非常有帮助的。谢谢。
浏览 10提问于2020-02-09得票数 1
回答已采纳
1回答
我有一个动态的dag，我使用它创建多个dag(不同的工作流)，它基于从lambda传递的值及其配置。如何触发动态dag脚本并从lambda触发dag？
浏览 6提问于2022-06-29得票数 -1
我正试图通过关注这个站点的来触发气流Dags。他们提供了一个curl命令curl -X POST \ http://localhost:8080/api/experimental/dags/<DAG_ID>/dag_runs \ -H 'Cache-Control: no-cache' \ -H 'Content-Type: application/json' \ -d &#x
浏览 8提问于2020-03-04得票数 1
回答已采纳
8回答
我有一个进程，我们将部署到多个不同的气流实例，在我们的airflow.cfg中，我们有dags_are_paused_at_creation = True，但是对于这个特定的进程，我们希望通过单击UI来打开它
浏览 8提问于2017-06-05得票数 16
回答已采纳
我想使用Appscript触发Google Composer airflow dag。有没有办法通过rest API或其他方式做到这一点。
如果可能，请提出解决方案。
浏览 1提问于2020-09-07得票数 1
Airflow提供rest API功能来提取dag/任务状态。https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#section/Trying-the-API但是想知道是否有一种方法可以仅获得所有dag w.r.t dag</
浏览 27提问于2021-08-26得票数 0
我们在一个节点中有一个controller_dag (应该触发目标dag的那个)，在另一个节点中有一个target_dag。我们已经能够从同一节点中的controller_dags触发target_dags。 是否可以从一个节点中的另一个target_dag触发另一个节点中的controller_dag？
浏览 40提问于2019-06-12得票数 1
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
