当我尝试从命令行运行 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():