首页 > 解决方案 > 将预定时间戳传递给 celery beat / redbeat

问题描述

我有一个问题,我试图找到一个答案一段时间。自去年以来,我一直在生产环境中使用 Celery Beat。我切换到 Redbeat 作为 Beat 处理程序,以便能够动态添加和删除任务。

问题很简单,如果我在时间 X 安排一个任务,有没有办法将 X 传递给该任务?

例如,如果一项任务安排在 11:00,是否有办法将该时间作为参数传递给该任务?这将非常有用,因为如果出于某种原因(消费者工作人员未运行)未在 11:00 而是在 11:30 执行该任务,我可以在任务内部知道最初所需的预定时间是 11:00 并且不是11:30!

如果您知道解决方案,也许还使用 Redbeat,请告诉我,这将非常有帮助!谢谢!

标签: pythoncelerycelery-taskcelerybeat

解决方案


推荐阅读