Django 芹菜与 RabbitMQ

Django Celery with RabbitMQ

我正在尝试 运行 使用 Celery 完成任务。我按照这个教程 link

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

Django by example 有完整的部分介绍如何将 Celery 与 RabbitMQ 结合使用。还有关于此主题的免费教程或文章

任务定义 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"])

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

对我来说效果很好。

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