1回答
文件中提到，当调度人员在2016-01-02上午6点选择DAG时，将创建一次DAG运行，execution_date为2016-01-01，下一次运行将在2016-01-03凌晨创建，执行日期为2016调度间隔是按小时提供的，执行日期是指DAG在结束时运行的时间段的开始，那么为什么不是在2016-01-02早上6点调度器挑选DAG的前一个小时呢？= DAG('tutorial', catchup=
浏览 77提问于2021-04-25得票数 1
2回答
我想在指定的日期运行一个简单的DAG。我正在努力改变开始日期、执行日期和回填之间的差异。运行DAG的命令是什么？以下是我尝试过的：当我第一次运行该命令时，任务正确地执行，但是当我再次尝试时，它没有工作。下面是我运行的另一个命令：我
浏览 7提问于2017-01-23得票数 20
回答已采纳
我在airflow中有一个DAG，目前它每小时运行一次(@hourly)。可以让它每5分钟运行一次吗？
浏览 0提问于2017-08-15得票数 17
我不明白触发一个运行并立即运行和保持它运行并让它完成它的工作之间的区别。代码没问题。
dag = DAG('hello_world', description='Simple tutorial DAG', schedule_interval='@hourly',catchup=Fa
浏览 32提问于2018-06-01得票数 1
回答已采纳
2回答
我的Dag 'owner': 'airflow', 'depends_on_past': False,}
dag = DAG('Hourly_test_2', schedule_interval='0 *
浏览 1提问于2020-01-10得票数 0
1回答
我是新来的气流，并试图运行一个简单的DAG每小时的费率。schedule_interval='@hourly'不起作用。我的期望是它将触发DAG从我的start_date (2022年10月7日凌晨)到现在每小时，因为追赶是默认设置为True。但是，它只触发一次z DAG，然后停止。气流版本为2.4.1from airflow.operators.
浏览 3提问于2022-10-08得票数 1
我们有一个按小时运行的气流数据集，任务更新和覆盖BigQuery中的日期分区表。在对这些表的查询和/或模式进行调整之后，我们想要回填几天的现有分区，但是回填所有运行都是巨大的浪费，因为每小时运行一次只会覆盖相同的分区24次，然后再转到第二天。我们可以使用airflow list_dag_runs列出所有运行并筛选出每天的最后一个运行，但是是否有一种方法可以每天只回填/清除这些最后的运行，而不需要每
浏览 3提问于2020-06-10得票数 0
回答已采纳
3回答
我在气流中创建了任务，我计划每小时运行一次，start_date设置为2016-11-16 'owner': 'airflow', # 'pool': 'backfill', # 'end_date': datetime(2016, 1,
浏览 6提问于2016-11-16得票数 1
回答已采纳
如果DAG具有一个在特定日期运行的start_date，那么如何定义相应的DAGRun的execution_date？/airflow/blob/master/airflow/example_dags/tutorial.pyfrom airflow import DAG 'ret
浏览 2提问于2018-03-10得票数 2
回答已采纳
有些每分钟运行一次，每天运行一次，还有一些使用cron每小时运行一次。现在我需要在气流中迁移。为此，根据气流的概念，我需要再创建20个文件(DAG文件)。airflow是否提供了创建通用dag模板的方法，该模板可以在给定的计划时间内使用不同的dag id执行所有的bash脚本？
我得到了一个参考- ，但我不确定，这是正确的方式还是错误的？
浏览 0提问于2020-01-07得票数 1
我用下面的配置做了一个DAG： default_args = { 'depends_on_past': False, 'email': ['francisco.salazar.12@sansano.usm.cl']= DAG<
浏览 10提问于2020-03-25得票数 1
回答已采纳
我有一个达格，每小时安排一次。假设凌晨1:00，凌晨2:00，凌晨3:00假设02:00被选中，但是如果01:00am dag运行仍在进行中，则需要取消02:00am实例。追溯(最近一次调用)：文件"/airflow/bd/pyenv&#
浏览 15提问于2020-11-17得票数 0
回答已采纳
我正在尝试实现两个DAG之间的DAG依赖，比如A和B。DAG A每小时运行一次，DAG B每15分钟运行一次。
如果DAG
浏览 4提问于2021-05-29得票数 4
我一直在评估airflow .I的使用案例，其中我有一个每小时运行一次的工作流，以获取每小时的数据聚合。另一个每天运行，以获取相同的每日聚合。是否可以创建一个组合工作流，其中只有在过去一天内所有每小时聚合都成功的情况下，才会运行每日聚合？我已经看到您可以创建子dags，但是这两个dags可以以不同的频率运行吗？如果是，是如何实现的？
浏览 0提问于2016-06-30得票数 7
我有一个DAG，它已经运行了超过十年的任务执行日期。现在我需要在开始的时候再加上一年。我用谷歌搜索了一下，建议在新的dag_id下做这件事。因为旧DAG已经在指定的执行日期范围内运行，所以我想将新DAG中的那些DAG标记为成功。我如何才能以一种方便的方式对其进行归档？
提前谢谢。这周有个好的开始。
浏览 2提问于2020-12-07得票数 0
1回答
上一次我忘记包括code样本时重新发布。
我能够获得一个基本的DAG运行(我可以在GUI中看到DAG及其运行对数据库的影响)，但似乎DAG不尊重schedule_interval参数。我试图让DAG每小时运行一次，但无论我做了什么更改，DAG都按每天的计划<e
浏览 0提问于2018-07-27得票数 1
回答已采纳
气流DAG发展的一个简单问题 'owner': 'Airflow', 'email': ['email1email_on_failure': True, 'schedule_interval': '0 * * * *',上
浏览 2提问于2022-06-11得票数 1
1回答
我想创建一个dag，它每小时运行一次，我们有一个导入和清理文件的cleanData进程，然后是一个storedata进程，它每天在上午8点和下午6点向我们发送两次报告如何在dag中包含时间？import pandas as pdfrom datetime import datetime
from airflow.operators.python_operatori
浏览 10提问于2021-07-16得票数 1
我目前使用的是Airflow (版本: 1.10.10)， 我对创建DAG很感兴趣，它将每小时运行一次， 这将带来Docker容器的使用信息(磁盘使用)， (可通过docker CLI命令( df -我在下面添加了我的示例DAG脚本， ? from airflow import DAGfrom dateti
浏览 40提问于2021-10-31得票数 0
回答已采纳
我在我的气流DAG中有两个任务。一个触发API调用( Http操作符)，另一个使用另一个api ( Http传感器)不断检查其状态。此DAG计划每小时& 10分钟运行一次。但有时一次执行可能需要很长时间才能完成，例如20小时。在这种情况下，前一个任务正在运行时的所有调度都不会执行。例如，如果我在01:10完成这项工作，需要10个小时.本应运行的调度02:10、03:10、04:10、... 11:10等被跳过，只执行12:10的调度。
我正在使
浏览 11提问于2019-08-09得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
