Сельдерей не настраивает разные очереди - PullRequest
Новая
       11

Сельдерей не настраивает разные очереди

0 голосов
/ 28 июня 2018

Я установил celery 4.1.1 и настроил очереди и маршруты, но работник принимает данные только через имя 'celery'. 

BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_DEFAULT_QUEUE = 'default'
CELERY_TASK_SERIALIZER = 'json'
CELERY_DEFAULT_ROUTING_KEY = "default"
CELERY_DEFAULT_EXCHANGE = "default"
CELERY_DEFAULT_EXCHANGE_TYPE = "direct"

CELERY_QUEUES = {
    'default': {
        "exchange": "default",
        "binding_key": "default"
    },
    'recon_queue': {
        "exchange": "recon_queue",
        "routing_key": "recon_queue"
    }
}

CELERY_ROUTES = {
    'reconciliation.tasks.sync_bag': {'queue': 'default'},
    'common.consumer.kafka_consumer': {'queue': 'recon_queue'}

}

CELERYBEAT_SCHEDULE = {
    "kafka_consumer": {
        'task': 'kafka_consumer',
        'schedule': crontab(minute='*/01'),
    },
}

Периодическое задание запускается с помощью сельдерея. Эта команда работает отлично - сельдерей -А адский рабочий -l инфо -Q сельдерей -c1 Этот работник выполняет все задачи сам.

Но эти команды не имеют никакого эффекта сельдерей -А адский рабочий -l информация -Q по умолчанию -c1 сельдерей -Производитель адов -l инфо -Q разведка -c1

...