Dramatq - потребитель обнаружил ошибку соединения - PullRequest
0 голосов
/ 04 апреля 2020

Когда я пытаюсь запустить dramatiq из командной строки, выдается следующее сообщение об ошибке. В настоящее время я использую RabbitMQ.

[Thread-2] [dramatiq.worker.ConsumerThread(default)] [CRITICAL] Consumer encountered a connection error: (406, "PRECONDITION_FAILED - inequivalent arg 'x-dead-letter-routing-key'for queue 'default' in vhost '/': received the value 'default.XQ' of type 'longstr' but current is none")

Это то, что я делал до сих пор.

import dramatiq
from dramatiq import get_logger


logger = get_logger(__name__)

@dramatiq.actor
    def myfunction():
...