這是我如何啓動芹菜定期任務的方式。首先,我執行以下命令: celery worker -A my_project.celery
而且這種命令後: celery -A my_project beat -l info -S django
在兩個不同的終端執行的選項卡這兩個命令後,我打芹菜週期性任務開始運行。如果我不運行其中一個描述的命令,我的定期任務不會運行。我的問題是:有沒有什麼辦法可以用單
我在我的Notification模型中有send_time字段。我想在當時向所有移動客戶端發送通知。 我在做什麼現在的問題是,我創建了一個任務,並安排它每分鐘 tasks.py @app.task(name='app.tasks.send_notification')
def send_notification():
# here is logic to filter notifica
我正在運行Django + Celery + RabbitMQ。在修改某些任務名稱後,我開始獲得「未註冊的任務」KeyErrors,即使在使用該鍵從Django Celery Beat的Periodic tasks表中刪除任務並重新啓動了Celery worker之後。 原來Celery/RabbitMQ tasks are persistent。我最終通過reimplementing the l