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

Question

我在气流中有一个DAG，现在它每小时运行一次（@hourly）。 每5分钟可以运行一次吗？

Answer 1

的documentation states：

每个DAG可能会或可能不会有一个时间表，这会通知DAG如何运行 创建。 schedule_interval被定义为DAG参数，并且 优选地将cron表达式作为str或 datetime.timedelta对象接收。

当按照提供的link for CRON expressions看来，您可以指定它为5 0 0 0 0 0每5分钟运行一次。

我对这件事并不熟悉，但这是文档所述。

Answer 2

是，这里的我所运行的每个5分钟的DAG的一个例子：

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

schedule_interval接受CRON表达式：https://en.wikipedia.org/wiki/Cron#CRON_expression