来自 RabbitMQ 的 message_count 不正确

问题描述

我有一些操作会消耗大量资源，所以我决定将它们排入队列。该功能运行良好，但我想在客户端的某处显示消息数量。

它是在 GraphQL subscription 内完成的，所以我每 10 秒获取一次当前状态。问题出在使用 queue_declare() 中的 Kombu 之后。

from kombu import Connection

def get_queue_message_count(channel,queue: str) -> int:
    _1,message_count,_2 = channel.queue_declare(
        queue=queue,passive=True,durable=True,auto_delete=False,arguments={"x-max-priority": 10}
    )
    print(f"{queue}: {message_count}")

    return message_count


async def generate_queue_status(_obj,_info) -> AsyncGenerator[Dict[str,Any],None]:
    with Connection(app_config.queue.broker) as connection:
        with connection.channel() as channel:
            while True:
                message_count = get_queue_message_count(channel,"actions")
                yield {"error": None,"messages": message_count}
                await asyncio.sleep(10)

第一次我得到正确的数字，其余的都是 0，即使管理工具中的消息总数大于 0：

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）