python - 使用 django 的消息

Question

是否可以在django中使用celery消费来自rabbitmq的消息？

消息是从另一个非 django 应用程序发送的

import os
from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')

app = Celery("test")
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.task_routes = { 
  'task.send_emails':{
    'queue': 'sendmail',
    'exchange': 'sendmail',
    'routing_key': 'sendmail'
 }
}
app.config_from_object('django.conf:settings')

Answer 1

Celery 创建的消息包含要执行的方法的名称及其参数列表 - 所以不，Celery 本身无法使用不是为现有注册的 Celery 任务以该格式创建的消息。

但是，您可以使用 Kombu为了实现这一点 - 它是 celery 的一部分，用于处理原始消息的创建和消费，并且非常易于使用。