aiohttp

内部已集成了aiohttp库，可以直接使用。目前只支持HTTP client功能。参考 aiohttp。

示例

import json
import asyncio
import aiohttp


async def get():
    async with aiohttp.ClientSession() as session:
        async with session.get("https://httpbin.org/get") as resp:
            print("status:", resp.status)
            print("headers:", resp.headers)
            body = await resp.text()
            print("body:", body)


async def post():
    async with aiohttp.ClientSession() as session:
        url = "https://httpbin.org/post"
        headers = {"Content-Type": "application/json"}
        payload = {"name": "micropython", "version": "1.24.1"}
        async with session.post(
            url=url, data=json.dumps(payload), headers=headers
        ) as resp:
            print("status:", resp.status)
            print("headers:", resp.headers)
            body = await resp.json()
            print("body:", body)


async def post_http11():
    async with aiohttp.ClientSession(version=aiohttp.HttpVersion11) as session:
        url = "https://httpbin.org/post"
        headers = {
            "Content-Type": "application/json",
            "Accept-Encoding": "identity",
            "Connection": "close",
            "TE": "identity",
        }
        payload = {"name": "micropython", "version": "1.24.1"}
        async with session.post(
            url=url, data=json.dumps(payload), headers=headers
        ) as resp:
            print("status:", resp.status)
            print("headers:", resp.headers)
            body = await resp.json()
            print("body:", body)


async def main():
    print("start aiohttp")
    await get()
    print("get ok")
    await post()
    print("post ok")
    await post_http11()
    print("post http11 ok")
    print("aiohttp done")


asyncio.run(main())