python - 使用 django 管理命令运行 celery 任务

Question

我正在尝试使用 celery 3.1 从自定义管理命令运行任务。

如果我从 View 调用我的任务，它工作正常，但是当从我的管理命令启动相同的任务时，该任务将仅在当前上下文中同步运行(而不是通过 celery 异步运行)。

我没有安装 djcelery。

我需要在管理命令中添加什么才能在命令行上进行异步任务处理？

Answer 1

从命令行实用程序执行 Celery 任务与从 View 执行它们相同。如果您有一个名为 foo 的任务，则在这两种情况下:

• 调用 foo(...) 会执行任务代码，就像 foo 只是一个普通的 Python 函数一样。

• 调用 foo.delay(...) 通过 Celery Worker 异步执行任务代码。