python - 带有 RabbitMQ 的 Django 芹菜

Question

我正在尝试用 Celery 运行任务。我按照这个教程链接

一切都已成功设置。现在的问题是我不知道如何执行任务。我运行 celeryd，它找不到任务。我想知道我需要调用什么来执行任务以及我需要如何在 RabbitMQ 服务器 django-admin 上配置任务。我找不到任何关于它的完整教程。

Answer 1

以 Django 为例，有一个完整的部分介绍了将 Celery 与 RabbitMQ 结合使用。还有关于这个主题的免费教程或文章

• 如何在 Django 上安装 Celery 并创建定期任务
• Django 芹菜第 1 部分
• Django 芹菜第 2 部分

Answer 2

任务定义 app/tasks.py：

from celery import shared_task

@shared_task
def add(param1,param2)
  print("task")

任务执行：

from celery import current_app
current_app.send_task("app.tasks.add", ["param1", "param2"])

Answer 3

这可能会帮助您了解如何运行 Celery。

它对我来说很好。

http://www.hiddentao.com/archives/2012/01/27/processing-long-running-django-tasks-using-celery-rabbitmq-supervisord-monit/