djangoからメッセージを消費する

Question

djangoでセロリを使用して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

に送信されている - ので、ノー、セロリ自体が消費することはできません既存の登録済みセロリタスクのためにその形式で作成されなかったメッセージ。

しかし、Kombuを使用すると、生のメッセージの作成と消費を処理するセロリの一部であり、使いやすいです。