aiohttp

The aiohttp library is integrated internally and can be used directly. Currently, only HTTP client functionality is supported. Reference: aiohttp.

Note

• By default, the client uses the HTTP/1.0 protocol; if it receives a 426 response status code, retries with HTTP/1.1 — see the example.

• Currently, aiohttp’s support for HTTP/1.1 is incomplete; actual usability must be verified through testing.

Example

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())