鼠兔在 celery 任务函数中发布

Question

由于某些原因，我得到了一些使用 pika 在 celery 任务中发布消息的代码。 代码如下：

@app.task
async def test_celery():
    with Rabbitmq_Helper() as connection:
        channel = connection.channel()
        channel.basic_qos(
            prefetch_size=0, prefetch_count=0
    )
        exchange_name = 'test'
        channel.exchange_declare(exchange=exchange_name, exchange_type='topic', 
durable=True)

    queue_name = "testtest"

    properties = pika.BasicProperties(delivery_mode=2)
    # body = msgpack.packb(clickhouse_utils.format_data(data, nodes), default=str)
    for i in range(100):
        body = "test data"
        print("send msg")
        channel.basic_publish(
            exchange=exchange_name, routing_key=queue_name, body=body, properties=properties
        )

在正式场景中，celery任务会延迟很多次。消费者函数将监视rabbitmq队列。

但在测试中，我发现消费者无法第一时间收到消息。并且芹菜可以发布队列中的消息。

所以我尝试调试，我像这样获取测试文件。但我发现芹菜任务延迟是正确的，但它无法发布队列中的消息。

发生了什么事？