我有一个正在运行的dag，我可以使用REST API停止它吗？有一种方法可以删除正在运行的dag：https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#operation/delete_dag
浏览 145提问于2021-10-09得票数 1
回答已采纳
是否可以在消息到达SQS队列时安排DAG运行？我还需要dag来处理队列中的消息。据我所知，这可以通过使用SQSSensor来完成，但我找不到任何示例，我对如何前进感到困惑。
浏览 24提问于2021-08-02得票数 0
我在我的气流DAG中有两个任务。一个触发API调用( Http操作符)，另一个使用另一个api ( Http传感器)不断检查其状态。此DAG计划每小时& 10分钟运行一次。我正在使用下面的脚本运行airflow服务器和调度程序。start_server.shexport AIRFLOW_GP
浏览 11提问于2019-08-09得票数 1
回答已采纳
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下删除按钮)
浏览 3提问于2020-06-11得票数 0
我想知道dag的状态是运行、失败还是成功。我正在通过CL参数airflow trigger触发dag，在作业执行之后，我想知道运行的状态。我找不到任何方法。我尝试了airflow dag_state，但它没有提供任何帮助。如果一天中有不止一次运行，通过命令行参数或python代码获取最近一次运行的状态，我应该怎么做？
浏览 35提问于2019-11-07得票数 3
回答已采纳
我们正在新旧气流之间进行迁移，我们试图实现从Airflow1到Airflow2的触发器(反之亦然)，这有可能吗？
浏览 3提问于2022-02-07得票数 0
回答已采纳
8回答
我有一个进程，我们将部署到多个不同的气流实例，在我们的airflow.cfg中，我们有dags_are_paused_at_creation = True，但是对于这个特定的进程，我们希望通过单击UI来打开它
浏览 8提问于2017-06-05得票数 16
回答已采纳
我正在尝试使用AirFlow rest API触发我的dag。但是，不能理解如何进行身份验证。 下面的URL在我的浏览器中运行良好。http://localhost:8181/api/experimental/dags/demo/dag_runs 但是，下面的代码会给出身份验证错误。import requestsfrom pprint im
浏览 24提问于2020-04-21得票数 2
4回答
基本上，我已经为任务准备好了脚本和dag，但该任务不会定期运行。相反，它需要在随机时间激活。(外部方会告诉我们是时候了，我们将运行它。在接下来的几个月里，这种情况可能会发生很多次。)有没有手动触发dag的方法？也欢迎任何其他方向/建议。谢谢。
浏览 3提问于2019-12-13得票数 6
需要帮助来提取所有任务的列表，以及当前状态成功/失败的当前进程运行。我有一个带有python操作符的任务，它在工作流的末尾执行。此任务的职责是返回与状态一起执行的任务的no。
浏览 10提问于2022-06-22得票数 0
回答已采纳
2回答
使用apache气流，我创建了一些DAGS，其中有些不按计划运行。编辑？？python脚本将从一个与我所有的DAGS所在的项目不同的项目中运行。
浏览 5提问于2020-02-04得票数 9
回答已采纳
我正在使用Apache Airflow REST API。 支持许多基本命令。例如，我可以通过运行以下命令返回特定DAG的信息： https://8080/my_url/api/experimental/dags/example_pig_operator/dag_runs ...which返回： [{
"dag_id": &qu
浏览 61提问于2021-06-19得票数 0
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
我遇到了一个问题，我可以从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
回答已采纳
从When服务器触发DAG并转到图形视图时，运行id如下所示： ? 我可以在命令行中使用'airflow trigger_dag‘并指定'run_id’来指定此名称，但我不知道如何在通过when服务器触发DAG时指定此ID？ 有没有人找到了这样做的方法？
浏览 84提问于2021-04-26得票数 2
我还想通过python触发列表中的任何DAG或停止其间的DAG 有没有什么Python API可以做到这一点？
浏览 42提问于2021-05-05得票数 1
用例: DAG定义了一个Rest任务(使用RestOperator)，它访问应用程序API并开始执行一个流程/任务，该流程/任务执行一些业务功能。它的执行状态由气流传感器监视，通过API调用轮询任务执行完成状态。如果芹菜节点发生故障，将如何处理运行在该节点上的传感器。如果传感器与工作人员一起死亡，如何将传感器执行传播到另一个节点(以避免functionality).丢失)。airflow.provider
浏览 5提问于2020-07-08得票数 0
1回答
我正在以一种复杂的方式运行一系列相互依赖的任务。我想将这些依赖关系描述为DAG (有向无环图)，并在需要时执行该图。我一直在关注airflow，并写了一个虚拟脚本： from datetime import datetime
from airflow.operators.python="3", python_callable=cloud_runner)
first_task >> [second_
浏览 64提问于2021-10-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
