2017-10-30 3 views
1

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') 
+0

여기 장고의 역할은 무엇입니까? 샐러리는 메시지를 소비하고 장고의 도움없이 작업을 수행 할 수 있습니다. –

답변

2

메시지가 실행되는 다른 비 장고 응용 프로그램에서 전송하며 매개 변수 목록입니다되고있다 - 그래서 아니, 셀러리 자체가 소비 할 수 등록 된 셀러리 작업에 대해 해당 형식으로 작성되지 않은 메시지

그러나 Kombu을 사용하면 원시 메시지 생성 및 소비를 처리하는 샐러리의 일부이며이를 사용하기가 매우 쉽습니다.

관련 문제