1回答
我已经创建了一个DAG，当我通过UI触发它时，它将被成功地执行。但是，当我使用命令行触发DAG时，DAG状态将开始运行，但任务将永远不会执行。对于下面图像的引用，DAG的ID是xcom_4_modules_ver_5
在通过调度的进程运行DAG并通过UI手动触发之后，我在CLI上执行airflow list_dag_runs x
浏览 1提问于2019-04-15得票数 8
1回答
我按照中的说明动态创建DAGs，通过变量k修改要创建的dags的数量from airflow import DAG我可以使用UI和CLI检查创建的DAG。两者是同步的：dag_id
浏览 16提问于2021-02-20得票数 2
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下删除按
浏览 3提问于2020-06-11得票数 0
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
Airflow老兵请帮帮忙 我正在寻找cron的替代品，偶然发现了apache airflow。 我们有一个设置，其中多个用户应该能够创建他们自己的DAG并计划他们的作业。我们的用户是可能不知道如何编写DAG python文件的混合用户。此外，他们可能无法访问运行airflow的服务器。 是否可以通过UI创建气流DAG。我找不到任何与此相同的引用。所有示例都讲述了如何创建一个python文件并将其上
浏览 155提问于2018-02-26得票数 21
回答已采纳
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。 "DAG_NAME", schedule_interval=None,default_args=args)airflow trigger_<em
浏览 2提问于2016-05-05得票数 24
最近，我将Airflow从1.9升级到1.10.3 (最新版本)。
但是，当放大SubDag时说当我们检查SubDag并发性时，它实际上是我们在代码中指定的8：
浏览 2提问于2019-05-09得票数 12
我试图通过一个python脚本在mysql中自动创建一个临时表，这个脚本集成在我的气流DAG (docker)上。我使用的脚本是通过一个外部python文件使用的，该文件将通过bashcommand运行。达格：
from airflow import DAG</em
浏览 4提问于2022-01-18得票数 0
在我对airflow的第一次尝试中，我尝试运行安装附带的一个示例DAGS。这是v.1.8.0。以下是我的步骤：[2017-04-19 15:32:38,391] {__init__.py:57} INFO-19 15:32:38,676] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software&
浏览 10提问于2017-04-20得票数 31
1回答
我是第一次接触Airflow，创建了我的第一个DAG。这是我的DAG代码。我希望DAG现在启动，然后每天运行一次。from airflow import DAGfrom datetime importspiders task_id='web_scrawl',
bas
浏览 2提问于2017-09-13得票数 1
我在airflow中创建了一个DAG，该DAG使用测试和回填命令成功运行，但当我从airflow UI手动运行它时，它会出错。有什么办法解决我的问题吗？注意，DAG在LocalExecutor中运行。在UI Airflow中记录错误：*** Fetching her
浏览 0提问于2017-10-31得票数 1
2回答
我希望为我的集群中的一些管道创建一个依赖图。我试图显示我的数据的起点和终点，以及这两个点之间的所有数据流。我希望使用apache airflow或apache falcon来完成这项任务。
浏览 19提问于2019-07-18得票数 1
我从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
1回答
我正在尝试创建一个使用DockerOperator执行某些脚本的DAG。在我的DockerOperator中，脚本试图读取气流变量并使用BaseHook获取连接。但是，我的DockerOperator中的脚本似乎连接到(空的) sqlalchemy数据库，而不是通过UI设置填充连接和变量的初始化postgres数据库。是否有一种方法可以将DockerOperator上下文提供给包含通过UI设置的连接和变量的气流数据库？我的气流
浏览 6提问于2022-06-02得票数 1
回答已采纳
是否可以在消息到达SQS队列时安排DAG运行？我还需要dag来处理队列中的消息。据我所知，这可以通过使用SQSSensor来完成，但我找不到任何示例，我对如何前进感到困惑。
浏览 24提问于2021-08-02得票数 0
我有一个sh文件，它存在于GCP计算引擎VM实例中。在同一服务帐户或同一项目中，我希望从GCP composer DAG执行该bash脚本。我们如何执行？ 我找到了一个解决方案，我不确定它是否正确。有一种方法可以使用"SSHExecuteOperator"；然后我们需要创建SSH连接。当composer和VM使用相同的服务帐户运行shell脚本时，我们还需要KeyFile吗？
浏览 20提问于2019-10-18得票数 1
我们通常使用trigger_dag命令启动Airflow DAG。例如：我们使用context[‘dag_run’].conf在运算符中访问此conf
有时，当DAG在某个任务中中断时，我们希望“更新”conf，并
浏览 6提问于2019-07-17得票数 3
我在代码中定义了以下DAG： from datetime import timedelta, datetimefrom airflow import DAGdata-push-for-red
data-push-for-yellow 然后，我通过在终端中输入以下内容来测试运行我的一个任务： airflow run现在，当我尝试从<em
浏览 49提问于2020-08-02得票数 1
回答已采纳
我在Google中使用Composer (气流)。我想要创建一个新环境，并将相同的DAG和变量从旧环境中移到新环境中。为了做到这一点，我做了以下工作：
然而，在新的环境中，由于FERNET_KEY configuration is m
浏览 5提问于2020-02-19得票数 6
回答已采纳
即使在配置文件中关闭了load_examples = False之后，气流示例仍然保留在UI中。
系统通知dag文件夹中不存在dag，但它们保留在UI中，因为调度程序已在元数据数据库中将其标记为活动。我知道从那里删除这些行的一种方法是直接删除数据库中的这些行，但是当然，这不是ideal.How，应该继续从UI中删除这些标记吗？
浏览 1提问于2017-06-28得票数 13
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
