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

Question

在这一点上，我已经阅读了大部分rabbitmq文档和celery文档，并多次阅读google soo。基本上，我在任何地方都找不到我需要的信息。

我有一个扭曲的and服务器读取传递给它的消息，并使用pika将消息放入队列中。这很好用。我现在遇到的问题就是我在这里做的事情。将会发生的情况是，我希望定期(使用celerybeat)使用队列中的当前内容。我遇到的一个大问题是，我不知道如何将任务传递到rabbitmq中，以便芹菜(或celerybeat)可以分配要完成的任务。

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

任何帮助都将不胜感激。

Answer 1

我不确定这是否有任何帮助，但我使用djcelery进行django中的任务队列，这是对兔mq的队列

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

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

Answer 2

我想我也有同样的问题，但让我重申一下，以确保：

是否可以使用Celery来使用由另一个非Django、非Celery进程放入RabbitMQ中的消息？例如，如果一个Java系统在购买时向RabbitMQ发送了一条消息，那么芹菜任务是否可以响应该消息并采取一些操作呢？