rabbitmq - RabbitMQ 和 django celery

Question

我正在使用 pika 客户端为某些 pub-sub 项目创建到 rabbitmq 的连接。直接调用客户端可以正常工作，但是当我尝试在 celery 任务中创建通道时出现错误。

意外引发：OSError(9, 'Bad file descriptor')

这是创建连接的代码

connection = pika.BlockingConnection(
pika.ConnectionParameters(
    host=get_secret("RABBIT_MQ_HOST"),
    credentials=pika_credentials.PlainCredentials(
        get_secret("RABBIT_MQ_USERNAME"),
        get_secret("RABBIT_MQ_PASSWORD")
    )
))
channel = connection.channel()

我在 connection.channel() 处遇到错误。

我如何在 celery 中创建连接（经纪人也是 rabbitmq）。