芹菜:启动工人后启动PeriodicTask

Question

我和芹菜http://celery.readthedocs.org/en/latest/index.html一起工作

我需要在特定的时刻执行一个定期的任务。但我只想在芹菜工人开始工作后开始我的工作。

为此，我试图创建自己的"PeriodicTask“。但我在处理一个问题。

当我启动工作程序并在另一个终端中执行run_tasks.py时，我的定期任务似乎只执行了一次。

怎样才能让我的定期任务每3秒运行一次。

下面是代码的一部分。

Start芹菜:

celery worker --app=worker_manager.celery  --loglevel=info 

文件tasks.py

class MyPeriodicTask(PeriodicTask):

    name = "periodic-task"
    run_every = timedelta(seconds=3)

    def run(self, **kwargs):

        logger = self.get_logger(**kwargs)
        logger.info("Running periodic task!")

文件run_tasks.py

tasks.register(MyPeriodicTask)

wmi_collector_task = worker_app.tasks[MyPeriodicTask.name]

提前谢谢。

Answer 1

要执行定期的任务，你需要开始芹菜节拍。在启动员工时，您可以通过传递-B参数来做到这一点：

celery worker -B --app=worker_manager.celery --loglevel=info