我想创建一个只能在外部触发器上运行的DAG (即，使用'airflow trigger_dag‘命令)。然而，当我这样做时，除了我想要的'scheduled_xxx‘之外，我还看到了多个'manual_xxx’DagRuns。我假设scheduled_xxx DagRuns是用来回填的？default_args=default_args)
task_id='date',
bash_command='date
浏览 4提问于2016-09-16得票数 0
我有一个气流DAG，我可以使用以下参数运行它： airflow trigger_dag 'my_dag' --conf '{"key":"value"}' 然后我可以像这样在我的DAG中获得'value做同样的事情： airflow backfill 'my_dag' --conf '{"key":"value"}' -s 2019-04-15 -e 2019-04-16
浏览 26提问于2019-04-17得票数 0
2回答
我喜欢从composer中重新运行或运行DAG，下面的命令是我所使用的，但是也有一些类似的例外。etc/airflow/airflow.cfg {backfill,list_tasks,clear,pause,unpause,trigger_dag
浏览 13提问于2020-07-14得票数 0
回答已采纳
我们有一个按小时运行的气流数据集，任务更新和覆盖BigQuery中的日期分区表。在对这些表的查询和/或模式进行调整之后，我们想要回填几天的现有分区，但是回填所有运行都是巨大的浪费，因为每小时运行一次只会覆盖相同的分区24次，然后再转到第二天。我们可以使用airflow list_dag_runs列出所有运行并筛选出每天的最后一个运行，但是是否有一种方法可以每天只回填/清除这些最后的运行，而不需要每天重新运行24个实例呢？我们可以使用airflow trigge
浏览 3提问于2020-06-10得票数 0
回答已采纳
同时，当我还在创建DAG来调度气流中的任务时。数据每天都在到达。因此，当我从今天开始运行我的DAG时，我想每天安排它，还想回填我在创建DAG时错过的过去几天的所有数据。我知道，如果我把start_date作为数据开始到达的日期，从那个日期开始回填，但那样的话，我的day将永远落后于今天吗？如何同时实现回填和调度？是否需要为回填和调度创建单独的DAG/任务？
浏览 0提问于2019-08-11得票数 2
我使用的是apache-气流1.10.10。airflow trigger_dag -c {"id":"2"} dag_common
airflow trigger_d
浏览 3提问于2020-06-18得票数 0
回答已采纳
我正在尝试理解气流中的追赶和回填。我知道什么是catchup，但我还没有完全理解backfill到底是什么，以及它是如何使用的。
我已经阅读了文档，但是找不到好的例子来理解回填。
浏览 14提问于2019-07-30得票数 3
回答已采纳
我看到可以使用airflow命令行使用参数/配置键-值对进行trigger_dag：
如何通过UI传递外部参数/配置？
浏览 7提问于2020-03-06得票数 8
回答已采纳
一切似乎工作正常，但在回填一些DAG运行后，Airflow崩溃并出现以下错误： [2019-06-06 12:13:25,378] {jobs.py:2521} INFO - Task exited with我应该在后台启动这个回填吗？(气流1.9)
浏览 15提问于2019-06-07得票数 0
1回答
在气流2.0中，有人知道如何从指令中回填吗？当我使用Airflow 1.0时，下面的命令对我起了作用，但是自从升级到2.0之后，子查询就出现了一些问题。命令为气流合成器1.0
gcloud composer environments run leo-stage-bi --location=europe-west1 backfill -- regulatory_spain_daily
浏览 2提问于2022-02-22得票数 1
我在codebuild中的容器中运行了一个气流，目前它执行所有的东西，但在触发DAG的部分它失败了。airflow scheduler > ~/scheduler.log 2>&1 & - airflow trigger_dag-sd $(pwd)/dags Pampa-------------------------------
浏览 1提问于2018-07-06得票数 1
我对气流很陌生。然而，我遇到了与新手在处理日程间隔时所面临的相同的时间和间隔问题。因此，我想尝试通过cli从外部触发DAG。这可以通过简单地进入控制台并输入example：airflow trigger_dag tutorial (使用airflow docker图像: 1.10.9)来完成。因此，我创建了一个类似以下内容的cron作业：* * * * * airflow trigger_dag tutorial 但是，这现在不会触发DAG。在其他一些实验中，我可以通过shell脚本中的相同命令手动触发D
浏览 21提问于2021-07-31得票数 0
在的帮助下，我刚刚编写了一个程序(如文章中所示)，当一个文件放置在S3桶中时，会触发运行中的一个DAG中的任务，然后使用BashOperator执行一些工作。我是否可以继续使用S3KeySenor来完成这个任务，或者是否需要找到一种方法来设置一个来运行我的DAG？到目前为止，如果我的S3KeySensor只运行一次的话，它是毫无意义的。更新：
我的用例非常简单，每当一个新文件被放置在指定的AWS S3桶中时，我希望我的DAG被触发，并开始处理各种任务。
浏览 1提问于2018-05-29得票数 25
回答已采纳
在本地，我使用这样的命令：问题是，这假设我是在本地运行。如何在带有参数的远程气流服务器上触发守护进程？我意识到我可以使用ui来点击play按钮，但这不允许您传递我所知道的参数。
浏览 0提问于2018-08-15得票数 2
回答已采纳
1回答
我读过关于回填的文章，但我不确定如何避免它，也不知道我做错了什么。有什么建议吗？是否可以从以前的执行中清除成功的运行结果？
浏览 0提问于2016-11-15得票数 0
我使用start_date和schedule_interval创建了DAG，如下所示： 'start_date': datetime(2020, 11, 16,/run.sh -p %s -e {{ next_ds }}' %(dir_path, phase),)
我打算每天午夜用过去几天的回填任务来执行我的任务。但是当我在气流网络UI中切换DAG时，任务就会被调度并立即运行。另外，调度程序根本不<
浏览 2提问于2020-11-20得票数 2
在气流中，我应该如何处理错误“此DAG在webserver DagBag对象中不可用，它显示在此列表中，因为调度程序将其标记为元数据数据库中的活动”？我将一个新的DAG复制到一个气流服务器上，并尝试：
调度程序日志显示它正在处理，没有出现错误，我
浏览 7提问于2017-04-28得票数 19
我试图在基于用户输入的气流中生成动态工作流。我知道可以选择基于文件和数据库的数据，但在所有这些情况下，工作流将不直接依赖用户输入，如果多个用户正在使用相同的数据，那么在这种情况下也可能会出现问题。为了避免所有这些，我正在考虑将用户输入传递给sub并生成工作流。但是subdag没有从ui传递用户输入的选项。
浏览 3提问于2020-11-30得票数 3
回答已采纳
1回答
气流大会的电流状态：abc_task >> ml_processors (all ml models from a to e run in parallelcompleted)问题陈述：是指机器学习模型之一(气流中的任务最后我在这里做了两个步骤：
d_p
浏览 3提问于2021-03-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
