安排DAG气流每5分钟运行一次

安排DAG气流每5分钟运行一次

本文介绍了安排DAG气流每5分钟运行一次的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我有一个DAG气流,现在它每小时运行一次(@hourly)。
是否可以每5分钟运行一次?

I have a DAG in airflow and for now it is running each hour (@hourly).Is it possible to have it running each 5 minutes ?

推荐答案

是的,这是我DAG的一个示例每5分钟运行一次:

Yes, here's an example of a DAG that I have running every 5 min:

dag = DAG(dag_id='eth_rates',
          default_args=args,
          schedule_interval='*/5 * * * *',
          dagrun_timeout=timedelta(seconds=5))

schedule_interval 接受CRON表达式:

schedule_interval accepts a CRON expression: https://en.wikipedia.org/wiki/Cron#CRON_expression

这篇关于安排DAG气流每5分钟运行一次的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

08-15 20:21