Сельдерей с помощью Python - PullRequest
Новая
       17

Сельдерей с помощью Python

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

Я запускаю Celery Worker при инициации Джанго- 

python manage.py runserver

Код моего работника сельдерея - 

from celery import current_app
from celery.bin import worker

class Worker:
    def start():
        app = current_app._get_current_object()
        worker = worker.worker(app=app)
        options = {
          'broker': 'amqp://guest:guest@localhost:5672//',
          'loglevel': 'INFO',
          'traceback': True,
        }
        worker.run(**options)

Сейчас я инициализируюсь в init.py в Django, поэтому он запускает рабочий, но, поскольку он не находится в демоне или каком-либо дочернем процессе, я не могу перейти к своим основным рабочим местам в django.

Я хочу, чтобы этот класс остался, так как я делаю универсальную библиотеку, чтобы несколько микросервисов могли использовать ее, просто импортируя эту библиотеку

Я получил этот рабочий код от - Как запустить рабочий Celery из скрипта / модуля __main __?

...