我将如何组合两个异步库？

Question

我将如何在同一个程序中组合两个 asyncio 库？

对于上下文，我希望使用Discord api与 aiohttp，它们都是异步事件循环驱动的。我可能也想在混合中添加一个异步 irc 库。

但是，我不明白它们将如何一起操作。我相信理论上我会实现该程序，以便所有类实例都使用相同的 asyncio 事件循环实例，然后将所有运行函数合并为一个，最终调用事件循环。

但是，我想知道是否有更优雅的方法来做到这一点？

Answer 1

只要所有库都使用相同的事件循环，它们就能很好地协同工作。在这种情况下，您选择的所有库似乎都基于 asyncio（除了 gawel 的 IRC 库，该库不再可用）。所以没有问题。有一个事件循环（并且没有线程），一切都很好。

您面临的问题是，您将在同一事件循环中拥有多个“服务器”，或者更准确地说，有多个协程处理来自外部世界的输入。一个协程正在处理 HTTP 流量，另一个协程正在处理 IRC“流量”。在伪代码中，它可以翻译为以下内容：

import asyncio



async def irc_server():
    async with irc_connect('irc.freenode.net#python-fr') as irc:
        async for message in irc:
            # do something useful with message

async def web_server():
    async with web_connect('localhost:8080') as web:
        async for request in web:
            # do something useful with request


loop = asyncio.get_event_loop()
loop.create_task(irc_server())
loop.create_task(web_server())

loop.run_forever()

因此，两个协程无法进行通信。要使 HTTP 部分与 IRC 部分通信，您必须在两个协程之间共享某些内容。在生产中，它可能是某种数据库，但在伪代码中，它是一个简单的全局数据库。你最终会得到这样的结果：

import asyncio


# value is shared between IRC and the web server.
value = None



async def irc_server():
    global value
    async with irc_connect('irc.freenode.net#python-fr') as irc:
        async for message in irc:
            # if message is echo, reply with the current value
            # otherwise store the message as value
            if message == 'echo':
                irc.send(value)
            else:
                value = message

async def web_server():
    global value
    async with web_connect('localhost:8080') as web:
        async for request in web:
            if request.path == 'echo':
                request.client.send(value)
            else:
                value = request.path  # this is silly but simple


loop = asyncio.get_event_loop()
loop.create_task(irc_server())
loop.create_task(web_server())

loop.run_forever()