如何使用 celery 和 django 运行已经在 rabbitmq 队列中的任务？答案

【问题标题】：How do I use celery and django to run tasks that are already in a rabbitmq queue?如何使用 celery 和 django 运行已经在 rabbitmq 队列中的任务？
【发布时间】：2011-11-22 20:24:34
【问题描述】：

此时我已经阅读了大部分rabbitmq 文档和celery 文档，并且google了很多遍。基本上我无法在任何地方找到我需要的信息。

我有一个扭曲的网络服务器读取传递给它的消息，并使用 pika 将消息放入队列中。这很好用。我遇到的问题是我从这里做的。会发生什么定期（使用 celerybeat）我想消耗当前队列中的内容。我遇到的最大问题是我不知道如何将任务传递给rabbitmq，以便芹菜（或celerybeat）可以分配要完成的任务。

问这个问题的最简单方法是：我可以读取以数据为主体的队列并在 django 中使用该数据吗？

任何帮助将不胜感激。

【问题讨论】：

标签： django rabbitmq celery

【解决方案1】：

我不确定这是否有任何帮助，但我使用 djcelery 从 django 进行任务队列，这个队列到 rabbit mq

一个单独的 python manage.py (celeryd|celerybeat) 进程根据 django 中的设置获取排队的任务

https://github.com/ask/django-celery

【讨论】：

【解决方案2】：

我认为我有同样的问题，但让我重申一下：

你可以使用 Celery 来消费由另一个非 Django、非 Celery 进程放入 RabbitMQ 的消息吗？例如，如果 Java 系统在购买时向 RabbitMQ 发送消息，Celery 任务是否可以响应该消息并采取一些行动？

【讨论】：