Welcome to aiosonic Discussions!

[sonic182]

👋 Welcome!

We’re using Discussions as a place to connect with other members of our community. We hope that you:

• Ask questions you’re wondering about.
• Share ideas.
• Engage with other community members.
• Welcome others and are open-minded. Remember that this is a community we
  build together 💪.

To get started, comment below with an introduction of yourself and tell us about what you do with this community.

[serg-yalosovetsky]

is aiosonic has a proxy?

[Arjunisawesome]

Yes aiosonic do have a proxy.

[sonic182]

is aiosonic has a proxy?

Yes -> https://aiosonic.readthedocs.io/en/latest/examples.html#use-a-proxy-server

[jiac3366]

hi @sonic182, I am excited to find out aiosonic, which is a great project.
When I design a benchmark between aiohttp and aiosonic, it seems performance of aiosonic is ~0.87 time of aiohttp's.
I am kind of confused by the result. Could u pls advice? Below is my code:

benchmark.py

import asyncio
import time
from decimal import Decimal

import aiohttp
import aiosonic

NUM_REQUESTS = 10000
TIMEOUT = 2
TEST_URL = "http://127.0.0.1:8080"


async def aio_request(session: aiohttp.ClientSession, index: int):
    try:
        async with session.post(
            TEST_URL, json={"key": "value"}, timeout=TIMEOUT
        ) as response:
            print(f"Aiohttp: Request {index} completed, status: {response.status}")
            return response.status
    except asyncio.TimeoutError:
        print(f"Aiohttp: Request {index} timed out")
        return None
    except Exception as e:
        print(f"Aiohttp: Request {index} failed: {str(e)}")
        return None


async def aiohttp_test():
    async with aiohttp.ClientSession() as session:
        tasks = []
        for i in range(NUM_REQUESTS):
            tasks.append(aio_request(session, i))

        start_time = time.time()
        results = await asyncio.gather(*tasks)
        end_time = time.time()

    successful_requests = sum(1 for result in results if result is not None)
    print(
        f"Aiohttp: {successful_requests}/{NUM_REQUESTS} requests completed successfully"
    )
    return end_time - start_time


async def aiosonic_request(client: aiosonic.HTTPClient, index: int):
    try:
        response = await asyncio.wait_for(
            client.post(TEST_URL, json={"key": "value"}), timeout=TIMEOUT
        )
        print(f"Aiosonic: Request {index} completed, status: {response.status_code}")
        return response.status_code
    except asyncio.TimeoutError:
        print(f"Aiosonic: Request {index} timed out")
        return None
    except Exception as e:
        print(f"Aiosonic: Request {index} failed: {str(e)}")
        return None


async def aiosonic_test():
    async with aiosonic.HTTPClient() as client:
        tasks = []
        for i in range(NUM_REQUESTS):
            tasks.append(aiosonic_request(client, i))

        start_time = time.time()
        results = await asyncio.gather(*tasks)
        end_time = time.time()

    successful_requests = sum(1 for result in results if result is not None)
    print(
        f"Aiosonic: {successful_requests}/{NUM_REQUESTS} requests completed successfully"
    )
    return end_time - start_time


async def run_benchmark():
    print(f"Running benchmark with {NUM_REQUESTS} requests")

    aiosonic_time = await aiosonic_test()
    aiohttp_time = await aiohttp_test()

    print(f"aiosonic completed in {aiosonic_time:.2f} seconds")
    print(f"aiosonic requests per second: {NUM_REQUESTS / aiosonic_time:.2f}")

    print(f"aiohttp completed in {aiohttp_time:.2f} seconds")
    print(f"aiohttp requests per second: {NUM_REQUESTS / aiohttp_time:.2f}")

    speedup = Decimal(aiohttp_time) / Decimal(aiosonic_time)
    print(f"aiosonic is {speedup:.2f}x faster than aiohttp")


if __name__ == "__main__":
    asyncio.run(run_benchmark())

server.py

from aiohttp import web
import json


async def handle_post(request):
    try:
        body = await request.json()
    except json.JSONDecodeError:
        body = {}

    response = {
        "args": {},
        "data": json.dumps(body),
        "files": {},
        "form": {},
        "headers": dict(request.headers),
        "json": body,
        "origin": request.remote,
        "url": str(request.url),
    }
    return web.json_response(response)


app = web.Application()
app.router.add_post("/", handle_post)

if __name__ == "__main__":
    web.run_app(app, host="127.0.0.1", port=8080)

Thanks!

[sonic182]

Why are you using asyncio.wait_for when doing client.post in aiosonic? Why not await the coroutine?

You may want to tune the values for TCPConnector https://aiosonic.readthedocs.io/en/latest/reference.html#connector-and-client-client

To specify a custom connector in the HTTPClient class