django - 在没有 worker 的情况下运行 celery 任务

Question

如何在没有 worker 的情况下运行所有​​ celery 任务，我的意思是直接调用？
我可以用TaskName.run()调用任务，但是我想在配置中写这个，那么如何制作呢？

Answer 1

只需设置 CELERY_ALWAYS_EAGER 设置为 true，这将强制 celery 不将任务排队并在当前进程中同步运行它们。

如果您希望能够按特定任务执行此操作，可以使用 运行它们。申请()或 运行()正如你提到的，而不是用 运行它们apply_async() 或 延迟() .

所以tl;博士:

CELERY_ALWAYS_EAGER = True
# The following two would do and act the same, processing synchronously
my_task.run() 
my_task.delay()

但

CELERY_ALWAYS_EAGER = False
# These two won't be the same anymore.
my_task.run() # Runs synchronously
my_task.delay() # Passed to the queue and runs Asynchronously, in another process