如何检查是否有DAG在Airflow中运行(在重新启动Airflow之前)？
在Airflow中检查是否有DAG在运行（在重新启动Airflow之前），可以通过以下步骤进行：
- 登录到Airflow的Web界面，通常可以通过浏览器访问
http://<Airflow服务器IP地址>:8080来访问。 - 在Web界面的导航栏中，点击"DAGs"选项卡，这将显示所有已配置的DAG。
- 在"DAGs"页面中，您可以查看每个DAG的状态。如果DAG正在运行，它将显示为"running"状态。如果DAG已经完成，它将显示为"success"状态。如果DAG失败，它将显示为"failed"状态。
- 您还可以通过点击特定DAG的名称，进入该DAG的详细信息页面。在该页面上，您可以查看DAG的运行历史记录、任务状态以及每个任务的日志。
- 如果您想要在重新启动Airflow之前停止正在运行的DAG，可以在"DAGs"页面中找到该DAG，并点击其右侧的"Pause"按钮。这将暂停该DAG的调度和执行。
请注意，以上步骤是基于Airflow的默认设置和Web界面操作。如果您的Airflow环境有自定义配置或使用其他工具进行管理，则可能会有所不同。
相关·内容
12回答
Airflow似乎跳过了我添加到/usr/local/airflow/dags中的dags。example_passing_params_via_test_commandexample_short_circuit_operatorexample_xcomlatest_only_with_trigger
t
浏览 0提问于2017-08-07得票数 29
12回答
DAG在Web中不可见
python、python-3.x、airflow、directed-acyclic-graphs
我是Airflow的新手。我遵循一个教程，并编写了下面的代码。from airflow import DAGfrom datetime import', python_callable=correctness_prediction,在运行脚本时，它不会
浏览 14提问于2016-08-17得票数 34
回答已采纳
4回答
Docker中的气流:如何将DAG添加到气流中？
docker、ubuntu、airflow
我想将DAG文件添加到Airflow中，它在Ubuntu上的Docker中运行。我使用了以下，其中包含配置和到docker镜像的链接。当我运行docker run -d -p 8080:8080 puckel/docker-airflow webserver时，一切都正常工作。但我找不到一种方法来安全地将DAG添加到气流中。此外，在home/root/dags中添加了一
浏览 3提问于2018-09-17得票数 10
2回答
Airflow DAG每秒运行，而不是每分钟运行
airflow、airflow-scheduler
我试图安排我的DAG每分钟运行一次，但它似乎是每秒钟运行一次。根据我所读到的所有内容，我应该只需要在我的DAG中包含schedule_interval='*/1 * * * *', #..every 1 minute，就是这样，但它不起作用。下面是我设置的一个简单示例来测试它：from airflow.operators import SimpleHttpOperator,
浏览 96提问于2018-06-05得票数 7
回答已采纳
2回答
我需要重新启动气流。我想确保我在它空闲的时候做，这样我就不会因为重新启动气流的worker组件而中断作业。 如何查看正在运行的DAG？ 我在UI中看不到任何列出当前正在运行的DAG的内容。我在airflow命令行界面中看不到任何用于列出当前正在运行的DAG的命令。我找到了可以连接到数据库的airflow shell，但我对Airflow<
浏览 37提问于2020-10-20得票数 0
回答已采纳
1回答
获取日志文件不存在:当试图在本地气流上运行一个进程时
python、ubuntu、airflow、directed-acyclic-graphs
我在我的ubuntu机器上本地运行气流，我的airflow.cfg文件在目录：/home/airflow/airflow中，所以我为我的dags创建了一个子目录，即/home/airflow/airflow我为检查示例输出而创建的dag是：
from <em
浏览 15提问于2022-11-13得票数 0
3回答
示例DAG无限期地停留在"running“状态
airflow
在我对airflow的第一次尝试中，我尝试运行安装附带的一个示例DAGS。这是v.1.8.0。以下是我的步骤：[2017-04-19 15:32:38,391] {__init__.py:57} INFOdag_state example_bash_operator '2017-04-19 15:32:38'
[2017-04-19 15:33:12,918]
浏览 10提问于2017-04-20得票数 31
1回答
用于requirements.txt更新的mwaa重新启动功能
airflow、requirements.txt、mwaa
每次我们的团队为我们的MWAA环境放置另一个requirements.txt文件时，都需要重新启动。所以，我的问题是:在MWAA的方式下，在这个过程中究竟什么是“重新启动”，为什么要应用到整个所谓的MWAA环境中？
浏览 10提问于2022-09-07得票数 0
回答已采纳
2回答
气流示例DAG在图形用户界面中需要很长时间，调度程序显示如下: DagFileProcessorManager (PID=...)上次发送的心跳信号
postgresql、sqlite、airflow、airflow-scheduler
在使用Airflow 2.1.2运行标准气流示例时，DAG需要很长时间才能完成。每次运行DAG时，都会出现此问题。从airflow GUI运行时出现问题。当从airflow命令行作为测试运行时，这不是问题。查看运行时的调度程序日志，这是显而易见的:在任务运行后，显然必须重新启动DagFileProcessorManager才能继续执行下一个任务，这需要1到2分钟。
浏览 84提问于2021-07-29得票数 0
2回答
google环境中的环境健康意味着什么？
google-cloud-platform、google-compute-engine、airflow、google-cloud-composer
在google环境中，有选项卡监控，它包含环境概述部分，第一个度量标准是环境健康。环境健康--显示编写器部署的运行状态的时间线。绿色状态并不意味着所有气流部件都可以运行，DAG也可以运行--它只反映了作曲家部署的状态。
但不确定环境有什么问题，以及当它发生时如何修复它。即使我的环境健康显示不健康，所有其他指标都是健康的，甚至气流也在运行。那么，请您解释一
浏览 0提问于2021-04-02得票数 2
回答已采纳
6回答
更新添加任务后找不到Airflow DAG任务
airflow
我在更新dag文件时遇到问题。Dag仍然保留着我的dag文件的旧版本。我添加了一个任务，但当我检查日志和UI (DAG->Code)时，它似乎没有更新。
我有非常简单的任务。我当然检查了airflow.cfg中的dag目录路径，并重新启动了airflow webserver/scheduler。我运行它没有问题(但使用旧的
浏览 23提问于2017-07-13得票数 5
2回答
Airflow :在每个任务运行大量实例时需要建议
directed-acyclic-graphs、airflow、apache-airflow
这是我在Stack上的第一篇文章，它是关于气流的。如果在下载过程中出现任何错误，我希望我的DAG自动从中止的步骤重试。因此，我在我的任务之上实现了一个循环，例如： t3.set_upstream(t2)
因此，在UI
浏览 1提问于2017-07-25得票数 2
1回答
如何删除Airflow中的默认DAG？
airflow、airflow-scheduler
你好，我是Airflow的新用户我已经启动了Airflow new服务器，我想在它上运行我自己的批处理，默认情况下有Airflow DAG。我尝试从图形用户界面中删除它们，然后按照说明从命令行界面中删除DAG，就像here所说的那样，但问题是它们会在一段时间后重新出现。我已经把Airflow的配置放到了airflow.cfg内部的False load_examples = False中，有没有什么解
浏览 53提问于2019-04-30得票数 1
回答已采纳
1回答
使用container - airflow隔离dag中的代码依赖关系
python、airflow
我正在尝试使用apache-airflow，并且我想探索Docker来在容器中运行任务。我当前的airflow安装在一个专用的virtualenv中，并且airflow会使用systemd自动重新启动。
我已经有多个项目想要在Airflow上进行。每个项目都应该有自己的dag。我希望用PythonOperator编写项目dag，并在docker容器中运行<
浏览 30提问于2020-05-07得票数 1
3回答
在码头气流上没有显示新的达格
docker、airflow、airflow-scheduler
问题:在码头气流上没有显示新达格，运行airflow dags list-import-errors时没有出现错误Dags路径在docker-compose.yaml中(这是默认路径)：/dags:/opt/airflow/dags然而，dags仍然没有显示在webserver UI和airflow
浏览 13提问于2022-09-06得票数 0
回答已采纳
2回答
气流调度器意外关闭
python-3.x、amazon-ec2、airflow、apache-airflow、airflow-scheduler
我在一个带有Ubuntu的EC2实例上运行airflow v1.8.0。我运行的各种DAG与几个不同的SQL表连接。我有一个反复出现的问题，由airflow scheduler -D引发的调度程序对我关闭了。当我检查airflow-scheduler.err时，没有错误。为了进行调试，我进入/airflow目录，使用rm airflow-scheduler*清除所有与调度程序相关的文件，然
浏览 14提问于2018-01-09得票数 2
回答已采纳
1回答
Apache气流不显示DAG
airflow
我面临一些问题，试图建立一个基本的DAG文件在气流(但我也有另外两个文件)。我通过Ubuntu使用LocalExecutor，并将我的文件保存在“C：\Users\tdamasce\Documents\工作区”中，其中包含了dag和日志文件。我的剧本是from airflow import DAG
浏览 5提问于2022-03-24得票数 0
回答已采纳
2回答
我从airflow dag_bag和相应的.pyc文件中删除了dag。当我尝试从airflow UI中删除相同的dag时，它显示此错误: Dag id MY_DAG_ID仍然在DagBag中。首先删除DAG文件。我使用的airflow版本是1.10.4，即使在重新启动airflow之后，我也无法从UI中
浏览 2提问于2019-12-03得票数 1
3回答
气流回填澄清
airflow
具体来说，有两个用例让我感到困惑：
如果我运行airflow scheduler几分钟，停止它一分钟，然后再次重新启动它，我的DAG似乎在前30秒左右运行额外的任务，然后继续正常运行(每10秒运行一次这些额外的任务是不是“回填”的任务在以前的运行中无法完成？如果是这样的话，我如何告诉气流不回填这些任务？如果我运行airflow schedul
浏览 6提问于2016-10-05得票数 46
回答已采纳
1回答
用气流测试和DebugExecutor调试气流任务
debugging、testing、airflow
我在我的IDE中寻找运行/调试任务和dags的最佳方法。我看到有两种方法可以这样做。我可以在调试模式下运行airflow test命令，用于特定的进程和可选的任务。其他方法是使用DebugExecutor并运行特定的dag。我看到这两种方法都要求气流数据库已经启动并运行，并且所有池都配置好了(可能还需要队列)。我的问题是：
这两者之间的主要区别是什么？airflow test在</
浏览 5提问于2020-11-29得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
