相关疑难解决方法(0)

使用aiohttp嵌套“与...同步”

我想创建一个使用aiohttp进行API调用的调度程序类。我尝试了这个:

import asyncio
import aiohttp

class MySession:
    def __init__(self):
        self.session = None

    async def __aenter__(self):
        async with aiohttp.ClientSession() as session:
            self.session = session
            return self

    async def __aexit__(self, exc_type, exc_val, exc_tb):
        if self.session:
            await self.session.close()

async def method1():
    async with MySession() as s:
        async with s.session.get("https://www.google.com") as resp:
            if resp.status == 200:
                print("successful call!")

loop = asyncio.get_event_loop()
loop.run_until_complete(method1())
loop.close()
Run Code Online (Sandbox Code Playgroud)

但这只会导致错误:RuntimeError: Session is closed。该__aenter__功能的第二种方法:

    async def __aenter__(self):
        self.session = aiohttp.ClientSession()
        return self
Run Code Online (Sandbox Code Playgroud)

效果很好。这是一个好结构吗?它不遵循如何使用aiohttp的示例。还想知道为什么第一种方法不起作用?

python python-asyncio aiohttp

3
推荐指数
1
解决办法
377
查看次数

标签 统计

aiohttp ×1

python ×1

python-asyncio ×1