Не удалось запустить рабочий процесс Celery с помощью Django в debug = False (production) - PullRequest
Новая
       17

Не удалось запустить рабочий процесс Celery с помощью Django в debug = False (production)

0 голосов
/ 29 апреля 2019

Это задача Celery для отправки электронной почты, забавно то, что все работает правильно в режиме DEBUG = True, но не работает в производстве DEBUG = False. Выполнение celery worker -A invoice2 --loglevel = debug во время действия отправки и в активированном режиме отладки показывает следующее: 

 ERROR/ForkPoolWorker-5] Task enviar_documentos[xxx] raised unexpected: TypeError("enviar_documentos_async() got an unexpected keyword argument 'cliente'",)

Сначала файл, который начинает отправку с задержкой: 

from django.conf import settings
from notifications.tasks import send_async_documents

def send_documents (company, client, documents, type, template = "invoice", context = None):
    send_documents = send_documents_async.delay
    send_documents (type = type,
                    company = company.pk,
                    client = client.pk,
                    template = template,
                    context = context)

Во-вторых, задача: 

from celery_app import app
@app.task (name = "send_documents")

def enviar_documentos_async (company, client, documents, type = "FacturaVenta", template = "invoice", context = None):
     if not context:
       context = {}
       klass = KLASS.get (type)
       queryset = klass.objects.filter (pk__in = documents)
       em = Empresa.objects.get (pk = company)
       cl = Cliente.objects.get (pk = client)
       .
       .
       return send_email(
           mail_from = "\"{0.name}\"><{0.email}>".format(em),
           mail_to = cl.email,
           type = template,
           context = context,
           attachments = attachments)

В-третьих, отправка электронного письма: 

from django.core.mail import EmailMessage
from django.template import Context, Template

def send_email(mail_from, mail_to, type, context = None, attachments = None):
   subject = Template(subject.type).render(mail_context) .replace ("\ n", "")
   message = Template(type.body).render(mail_context)
   ...
   msg = EmailMessage (
          subject,
          linebreaks (message),
          mail_from,
          mail_to)

Версии приложений, установленных pip в virtualenv: 

   celery 4.3.0

   Django 2.1.1

   django-extensions 2.0.7

   django-filter 2.1.0

   django-oauth-toolkit 1.1.3

   django-redis 4.10.0

   django-redis-cache 2.0.0

   djangorestframework 3.8.2

   redis 3.2.1

   redis-cache 0.1.5

   redis-structures 0.1.7

   kombu 4.5.0

На сервере Linux-4.9.0-3-amd64-x86_64-with-debian-9.0 + nginx / 1.10.2 + uwsgi 2.0.17.1:

Redis server v = 5.0.4 sha = 00000000: 0 malloc = jemalloc-5.1.0 bits = 64
Celery 4.3.0 (rhubarb)

Часть Settings.py 

DJANGO_ROOT = dirname (abspath (__ file__))
SITE_HTDOCS = normpath (join (DJANGO_ROOT, '../htdocs'))
STATIC_ROOT = normpath (join (SITE_HTDOCS, 'static'))
STATIC_URL = '/static/'
MEDIA_ROOT = normpath (join (SITE_HTDOCS, 'media'))
MEDIA_URL = '/media/'
...
# CELERY
BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

Ответы [ 2 ]

0 голосов
/ 29 апреля 2019

С Django в производстве debug = False, Celery не работает напрямую, запустив: celery worker -A myapp --loglevel=info, также необходимо запустить сценарии Celery демонизация 

bin/celery worker --help

Параметры встроенного ритма: -B, --beat Также запустить планировщик периодических задач сельдерея бить. Обратите внимание, что должен быть только один экземпляр этот сервис. .. note :: -B предназначен для цели развития. Для производственной среды вы нужно начинать сельдерей бить отдельно.

ВАЖНЫЙ параметр: -B celery worker -A myapp --loglevel=info -B

0 голосов
/ 29 апреля 2019

Где вы вызываете функцию enviar_documentos_async? Вероятно, опечатка, в которой вы предоставляете аргумент client (клиент, а не клиент).

...