mitmproxy asyncio request

addon.py

from mitmproxy import http
import asyncio


def request(flow: http.HTTPFlow):
    flow.intercept()

    async def resume():
        try:
            await async_request(flow)
        except Exception as e:
            flow.response = http.Response.make(500, f'mitmproxy intercept error: {e}\n')
        flow.resume()

    asyncio.create_task(resume())


async def async_request(flow: http.HTTPFlow):
    await asyncio.sleep(3)
    print(flow.request.query)
    flow.request.query['async'] = ''