Skip to main content

Async functions to compare with anyio and asyncio, and toolkit to read excel with async/await.

Project description

asynctor

Python Versions LatestVersionInPypi GithubActionResult pre-commit Coverage Status Mypy coverage Ruff

Some async functions that using anyio, and toolkit for excel read.

Installation

$ pip install asynctor
---> 100%
Successfully installed asynctor

with extras:

pip install "asynctor[xls,redis,fastapi]"

Or by pdm:

pdm add "asynctor[redis]"

Usage

  • Async function that compare asyncio but use anyio: bulk_gather/gather/run
>>> import asynctor
>>> async def foo():
...     return 1
...
>>> await asynctor.bulk_gather([foo(), foo()], limit=200)
(1, 1)
>>> await asynctor.gather(foo(), foo())
(1, 1)
>>> asynctor.run(gather(foo(), foo()))
(1, 1)
  • timeit
>>> import time
>>> import anyio
>>> from asynctor import timeit
>>> @timeit
... async def sleep_test():
...     await anyio.sleep(3)
...
>>> await sleep()
sleep_test Cost: 3.0 seconds

>>> @timeit
... def sleep_test2():
...     time.sleep(3.1)
...
>>> sleep_test2()
sleep_test2 Cost: 3.1 seconds
  • AioRedis

pip install "asynctor[redis]"

from asynctor.contrib.fastapi import AioRedis, register_aioredis
from fastapi import FastAPI

app = FastAPI()
register_aioredis(app)

@app.get('/')
async def root(redis: AioRedis) -> list[str]:
    return await redis.keys()

@app.get('/redis')
async def get_value_from_redis_by_key(redis: AioRedis, key: str) -> str:
    value = await redis.get(key)
    if not value:
        return ''
    return value.decode()
  • AsyncTestClient pip install "asynctor[fastapi]"
import pytest
from asynctor import AsyncTestClient, AsyncClientGenerator
from httpx import AsyncClient

from main import app

@pytest.fixture(scope='session')
async def client() -> AsyncClientGenerator:
    async with AsyncTestClient(app) as c:
        yield c

@pytest.fixture(scope="session")
def anyio_backend():
    return "asyncio"

@pytest.mark.anyio
async def test_api(client: AsyncClient):
    response = await client.get("/")
    assert response.status_code == 200
  • Read Excel File(need to install with xls extra: pip install "asynctor[xls]")
>>> from asynctor.xls import load_xls
>>> await load_xls('tests/demo.xlsx')
[{'Column1': 'row1-\\t%c', 'Column2\nMultiLines': 0, 'Column 3': 1, 4: ''}, {'Column1': 'r2c1\n00', 'Column2\nMultiLines': 'r2 c2', 'Column 3': 2, 4: ''}]

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

asynctor-0.8.4.tar.gz (30.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

asynctor-0.8.4-py3-none-any.whl (17.5 kB view details)

Uploaded Python 3

File details

Details for the file asynctor-0.8.4.tar.gz.

File metadata

  • Download URL: asynctor-0.8.4.tar.gz
  • Upload date:
  • Size: 30.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.9.23

File hashes

Hashes for asynctor-0.8.4.tar.gz
Algorithm Hash digest
SHA256 edcf1a31f8ca540f47a1dbd19cfec4d0043e456135911429112305d0f71e797a
MD5 f51dca06e776a9dda5c9e09fd8643076
BLAKE2b-256 0fe406eae4b5bfc88fc05ed480f1feabaf78541bcbbe4ff9ea3ce8d688f168d6

See more details on using hashes here.

File details

Details for the file asynctor-0.8.4-py3-none-any.whl.

File metadata

  • Download URL: asynctor-0.8.4-py3-none-any.whl
  • Upload date:
  • Size: 17.5 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.9.23

File hashes

Hashes for asynctor-0.8.4-py3-none-any.whl
Algorithm Hash digest
SHA256 182237654d9a929bd6d59e90f0a4a187369f690a012426b368f25ff74805e80f
MD5 f0eb8d0cef751dde019ef8bdb83d23a6
BLAKE2b-256 94a078cd46006a77b6ef1c2bd284d54f3bb2e88fc130f1422d0a049fee4da726

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page