你好，我是Airflow的新用户我已经启动了Airflow new服务器，我想在它上运行我自己的批处理，默认情况下有Airflow DAG。我尝试从图形用户界面中删除它们，然后按照说明从命令行界面中删除DAG，就像here所说的那样，但问题是它们会在一段时间后重新出现。我已经把Airflow的配置放到了airflow</
浏览 53提问于2019-04-30得票数 1
回答已采纳
13回答
我已经启动了Airflow网络服务器并安排了一些dags。我可以在web GUI上看到dags。
如何删除正在运行并在web GUI中显示的特定DAG？是否有Airflow CLI命令来执行此操作？我环顾四周，但找不到一个简单的方法来删除一个DAG，一旦它已经加载和调度。
浏览 360提问于2016-11-17得票数 83
回答已采纳
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下<em
浏览 3提问于2020-06-11得票数 0
我试图安排我的DAG每分钟运行一次，但它似乎是每秒钟运行一次。根据我所读到的所有内容，我应该只需要在我的DAG中包含schedule_interval='*/1 * * * *', #..every 1 minute，就是这样，但它不起作用。下面是我设置的一个简单示例来测试它：from airflow.operators import S
浏览 96提问于2018-06-05得票数 7
回答已采纳
1回答
我按照中的说明动态创建DAGs，通过变量k修改要创建的dags的数量from airflow import DAG我可以使用UI和CLI检查创建的DAG。两者是同步的：dag_id
浏览 16提问于2021-02-20得票数 2
我从airflow dag_bag和相应的.pyc文件中删除了dag。当我尝试从airflow UI中删除相同的dag时，它显示此错误: Dag id MY_DAG_ID仍然在DagBag中。首先删除DAG文件。我使用的airflow版本是1.10.4，即使在重新启动
浏览 2提问于2019-12-03得票数 1
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。 "DAG_NAME", schedule_interval=None,default_args=args)airflow trigger_dag
浏览 2提问于2016-05-05得票数 24
通过GCP命令将文件上传到DAG文件夹后，我想检查是否创建了DAG。我可以知道检查是否创建了暂停的DAG的命令吗？在这个问题中，我提到了"Pause DAG“，因为我使用的是"core-dags_are_paused_at_creation=true”配置。
存在load_dags，但它仅返回未暂停的DAG。
浏览 3提问于2020-01-14得票数 0
1回答
我正试着在气流中做些蜂窝作业。我建立了custome连接，您可以在图像中看到它。我可以通过airflow web (数据分析->即席查询)查询蜂箱表。=dag# defining the job dependency然而，当我在气流中运行这项工作时，我遇到了一些错误：
ERROR jdbc.Utils的任何服务器URI打开客户端传输。它不在允许在运行时修改的参数列表中(state=08S01，code=0
浏览 0提问于2019-03-13得票数 3
3回答
我想从气流UI中删除一个DAG，这在GCS/dags文件夹中不再可用。我知道气流有一种使用airflow delete_dag my_dag_id命令从DB中删除dags的“新”方法，这在中可以看到。在composer气流版本中，似乎还不支持delete_dag命令。不尝试这样做：--我也尝试过使用airflow resetdb --而
浏览 1提问于2018-05-31得票数 5
回答已采纳
2回答
我们有一个连续的集成管道，自动将我们的气流DAG部署到气流服务器。在部署新版本的DAG时，默认情况下其状态为OFF。我们希望将其转换为ON，作为部署过程执行的任务的一部分。气流中是否有允许打开DAG的命令行选项？谢谢
浏览 3提问于2017-11-22得票数 6
回答已采纳
我知道有一种方法可以删除DAG。但是，是否可以删除具有特定run_id的DAG运行？类似于：
airflow delete_dag_run <dag_id> <run_id>
浏览 0提问于2019-10-19得票数 13
我对使用apache airflow非常陌生。我使用pycharm作为我的IDE。我创建了一个项目(anaconda环境)，创建了一个包含DAG定义和Bash操作符的python脚本。当我打开airflow When服务器时，我的DAGS不显示。仅显示默认示例DAG。我的AIRFLOW_HOME变量包含~/airflow。所以我在那里存储了我的python脚本，现在它显示
浏览 2提问于2019-07-04得票数 7
回答已采纳
我正在尝试为我的所有dags设置两个默认值。为此，我使用以下代码在Airflow的主目录中创建了文件airflow_local_settings.py (尝试遵循https://airflow.apache.org/docs/apache-airflow/stable/concepts.html#dag-level-cluster-policy中的<
浏览 7提问于2021-04-20得票数 1
回答已采纳
如何获取在具有dag-id的airflow dag中运行的任务列表？任务之间的连接并不重要。谢谢
假设我有来自"airflow list_dags“的dag-id
浏览 94提问于2019-07-30得票数 2
我试图通过运行正式的气流对接器来学习一点气流，按照这里的指令组成图像: https://airflow.apache.org/docs/apache-airflow/2.0.1/start/docker.html我能够启动所有这样的服务，当我将我的测试DAG放在./dags文件夹中时，我最终在UI中看到了我的DAG并可以运行它。
但这花了
浏览 4提问于2022-11-30得票数 1
回答已采纳
我使用的是airflow 1.10.12，但发现下游任务会被调度器调度很长时间后其上游任务完成，这是非常奇怪的。例如，这里是甘特图，你可以发现任务是在其上游任务完成1分钟后安排的，有什么方法可以让它运行得更快吗？
浏览 0提问于2020-11-17得票数 0
当尝试通过airflow trigger_dag test_dag运行dag时，我得到了错误：airflow.exceptions.DagNotFound: Dag id test_task not found运行airflow list_dags时，DAG正确列出。我还进行了检查，以确保将$AIRFLOW_HOME目录正确设置为dag所在的位置。我能让它工作的唯一方法就是运行一个
浏览 8提问于2019-09-12得票数 3
我正在试用ZenML，它说它可以将我的.py管道转换为气流DAG。我遵循了这里的每一步：https://docs.zenml.io/guides/low-level-api/chapter-7，都成功了 我的管道在本地运行良好，但是为什么看不到在airflow UI上创建的DAG？UI完全是空的. 问题似乎是，ZenML将复制我以ZenML方式编写的.py管道，并期望它可以在气流<em
浏览 68提问于2021-11-14得票数 1
回答已采纳
我最近将airflow版本从airflow 1.8升级到apache-airflow 1.9，升级成功，我使用Celery Executor扩展了环境，一切似乎运行正常，但dag和任务开始日期、执行日期等都显示在UTC时区，计划的dag在UTC运行，在升级之前他们使用的是本地时区，即pdt。关于如何将pdt设置为airflow中的默认时区，有什么建议吗？我尝试在airflo
浏览 2提问于2018-01-11得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
