python - 非阻塞 RabbitMQ 消费者 - Python3

Question

我正在寻找一个用 python3.7 编写的最新的rabbitMQ 消费者，它可以并行处理消息。

我已经找到：

https://github.com/mosquito/aio-pika和 https://pika.readthedocs.io/en/0.12.0/examples/asyncio_consumer.html

AIO-PIKA 仅在存在 a 时才能正常工作asyncio.sleep(1)，但我不明白为什么，如果我使用如下示例（减去 async 内容），asyncio_consumer 示例无法异步工作。

async def find_divisibles(inrange, div_by):
    print("finding nums in range {} divisible by {}".format(inrange, div_by))
    located = []
    for i in range(inrange):
        if i % div_by == 0:
            located.append(i)
        if i % 50000 == 0:
            await asyncio.sleep(0.0001)

    print("Done w/ nums in range {} divisible by {}".format(inrange, div_by))
    return located

（来自：https ://pythonprogramming.net/asyncio-basics-intermediate-python-tutorial/ ）

标签： pythonpython-3.xasynchronous