셀러리 작업 - 데이터베이스에 레코드 삽입이 작동하지 않습니다.

Question

셀러리 (셀러리 4.1, 파이썬 3, 장고 1.10)를 처음 사용했습니다. 그리고 나는 주 데이터베이스에 레코드를 삽입하는 간단한 작업을하고있다. 이상한 생각은 오류 메시지가 나타나지 않지만 레코드가 데이터베이스에 삽입되지 않은 것입니다. 여기 코드는 다음과 같습니다

views.py : 나는 표준 파이썬 함수로 .delay() 및 전화 test()을 제거하면

def test_view(request): 
    test.delay() 
    return HttpResponse() 

이

from __future__ import absolute_import, unicode_literals 
from celery import task 
from main.models import EmailDialog 

@task() 
def test(): 
    a = EmailDialog() 
    a.save() 

, 나는 레코드가 데이터베이스에 나타납니다 볼 tasks.py . 그러나 .delay() 부분을 다시 추가하면 레코드가 추가되지 않습니다. 나는 어느 방향으로 파 내려야하는지 궁금하다.

P. similar question을 보았지만 문제를 해결하는 데는 도움이되지 않았습니다.

Answer 1

셀러리 작업자가 시작되지 않은 경우 시작하십시오. 의사에 따라 셀러리 구성이 모두 완료되었는지 확인하십시오. 메시지 브로커가 제공되었는지 확인하십시오.