1回答
我需要dag_run_start_date作为时间戳，但由于某些原因，每个任务的时间戳都不同。有人有解决这个问题的办法吗？ 我还想知道是否可以只打印出启动此dag或启动第一个任务的时间。在我的情况下，什么是正确的方法？dag = DAG( start_date=datetim
浏览 25提问于2021-11-14得票数 0
我有一些DAG用于查询数据库中的记录，这些记录是在24小时内在时间窗口内创建的，因此：我正与气流调度系统作斗争，因为现在，它们总是在24小时后执行，但我希望时间表在每次窗口之后运行，这样我就可以更快地获得今天的数据，而不必等到第二天。有人能解释一下我是怎么做到的吗？
浏览 7提问于2022-05-10得票数 0
3回答
我正在尝试为从rds postgres到另一个postgres rds的数据提取实现增量数据加载。如果我的上一次执行日期是None或null或''：从时间的开始(在我们的例子中是一年前)选择数据，否则选择上一
浏览 0提问于2020-11-02得票数 0
是否可以在消息到达SQS队列时安排DAG运行？我还需要dag来处理队列中的消息。据我所知，这可以通过使用SQSSensor来完成，但我找不到任何示例，我对如何前进感到困惑。
浏览 24提问于2021-08-02得票数 0
我设置了airflow并运行了一些day，计划每天运行一次"0 0** *“。
我想检查下一次计划运行特定dag的时间，但我看不到在管理员中哪里可以做到这一点。
浏览 1提问于2018-09-07得票数 12
回答已采纳
1回答
下面是一个最小的可重复的例子。我预计test和test2都会打印相同的时间戳，但它们在气流中打印不同的时间戳(间隔几秒钟)。import datetimefrom airflow.operators.python_operator import PythonOperator(
'airflow_test'
浏览 6提问于2022-05-24得票数 0
2回答
我想在指定的日期运行一个简单的DAG。我正在努力改变开始日期、执行日期和回填之间的差异。运行DAG的命令是什么？以下是我尝试过的：当我第一次运行该命令时，任务正确地执行，但是当我再次尝试时，它没有工作。下面是我运行的另一个命令：
airflow backfill dag_1 -s 2017-1
浏览 7提问于2017-01-23得票数 20
回答已采纳
我有一个气流DAG，这是没有意义的回填。我想，使用气流1.8，你可以给DAG参数catchup=False，所以它只会开始最近的工作。也就是说，我想让DAG从午夜开始，每天运行。但。这就是现在的事情: DAG立即开始，而不是在午夜。另外，当我清除所有DAG运行时，它将立即重新启动。然后DAG将每天运行，但将在错误的时间安排它开始
浏览 3提问于2017-11-22得票数 2
回答已采纳
在追赶设置中，我注意到执行日期正确地对齐，但是当我像这样关闭追赶设置时：from airflow import DAG 'schedule_interval': '@daily'
dag = DAG('xiang-01&#x
浏览 4提问于2018-09-11得票数 0
回答已采纳
在Airflow中，我们使用xcoms来表示一个DAG已经完成，另一个可以开始运行。例如，DAG 1在上午12点运行，并在完成时发送xcom。DAG 2从DAG 1读取xcom。https://airflow.apache.org/docs/stable/_modules/airflow/models/xcom.html 举个例子，假设我有4个DAG，<e
浏览 19提问于2020-06-11得票数 0
是否有一种方法可以在气流中找到 all DagRun实例的最大/最小甚至平均持续时间?也就是说，所有dag中的所有dag，而不仅仅是一个dag。在UI上，甚至在带有编程/命令行示例的页面上，我都找不到可以这样做的地方。
浏览 3提问于2022-06-29得票数 0
我是GCP的新手。我有一个在GCP环境中创建的样例python脚本，运行良好。我想在Airflow中安排这个。我将文件复制到环境(gs://us-west2-*******-6f9ce4ef-bucket/dags)中的DAG文件夹中，但它显示在airflow DAG中。这是airflow配置中的位置。dags_folder = /home/airflow/
浏览 7提问于2021-03-11得票数 0
3回答
': False, 'email': ['airflow@airflow.com'], # 'pool': 'backfill', # 'end_date': datetime(2016, 1
浏览 6提问于2016-11-16得票数 1
回答已采纳
我使用kwargs‘execution’来获取dag的执行日期，但它给出了调用整个dag的时间，但我需要特定任务在airflow中开始和结束的时间。
浏览 2提问于2020-05-02得票数 0
1回答
但是，当我使用命令行触发DAG时，DAG状态将开始运行，但任务将永远不会执行。对于下面图像的引用，DAG的ID是xcom_4_modules_ver_5
在通过调度的进程运行DAG并通过UI手动触发之后，我在CLI上执行airflow list_dag_runs xcom_4_modules_ver但是，在执行命令airflow trigger_dag -sd /usr&
浏览 1提问于2019-04-15得票数 8
在airflow.cfg文件中，我将min_file_process_interval值配置为120秒。达格在每分钟后都有时间间隔运行。我将min_file_process_interval更改为200秒，然后在200秒后开始执行dag计划。澄清一下，如果情况相反，即dag调度间隔为2分钟，min_file_process_interval为1分钟，则dag将按照其日程运行良好。下面是我的爸爸：
from airflow import DAG<
浏览 0提问于2019-05-14得票数 0
回答已采纳
我想我已经阅读了气流文档中关于调度的所有文章，但我似乎仍然不能让我的DAG运行在start_date+schedule_interval之后(即没有任务实例)。我用的是码头。with no luckCMD airflow scheduler -d DAG_id
我使用的是PythonOperator和一个加载我编写的库的模块我不确定这是否是正确的<
浏览 1提问于2017-03-10得票数 0
Airflow似乎跳过了我添加到/usr/local/airflow/dags中的dags。当我跑的时候输出如下所示example_xcomlatest_only_with_trigger
t
浏览 0提问于2017-08-07得票数 29
1回答
我们正在探索使用Apache Airflow来取代当前ETL的orchestrator工具。我们目前的ETL有600多个不同的任务，具有复杂的依赖关系。这些任务主要是对Informatica PowerCenter工作流的调用，但也有少量数据库过程和shell脚本 为了测试UI，我创建了一个包含600个任务的DAG。我没有使用我创建的实际自定义操作符，而是使用了开箱即用的BashOperator来打印</em
浏览 21提问于2020-04-04得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
