使用aiohttp库时,可以使用asyncio
来实现异步处理请求。下面是一个例子:
import asyncio
import aiohttp
async def fetch(session, url):
async with session.get(url) as response:
return await response.text()
async def main():
async with aiohttp.ClientSession() as session:
response = await fetch(session, 'http://example.com')
print(response)
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
在上面的例子中,fetch
函数用于发送请求并获取响应的文本内容。main
函数是整个程序的入口,它创建了一个ClientSession
对象,并调用fetch
函数来发起请求。最后,使用asyncio
的事件循环来运行main
函数。
通过使用asyncio
和await
关键字,可以实现在aiohttp中异步处理请求。