Aiotaskqueue is a type-safe and fast distributed queue alternative to celery, rq and arq.
Example Usage
import asyncio
from redis.asyncio import Redis
from aiotaskqueue import Configuration, Publisher, TaskRouter
from aiotaskqueue.broker.redis import RedisBroker, RedisBrokerConfig
from aiotaskqueue.serialization.msgspec import MsgSpecSerializer
from aiotaskqueue.serialization.pydantic import PydanticSerializer
router = TaskRouter()
@router.task(name="task-name")
async def task(a: int, b: str) -> None:
print(a, b)
async def main() -> None:
configuration = Configuration(
serialization_backends=[PydanticSerializer()],
default_serialization_backend=MsgSpecSerializer(),
)
redis = Redis(host="127.0.0.1")
broker = RedisBroker(
redis=redis,
consumer_name="aiotaskqueue",
broker_config=RedisBrokerConfig(xread_count=100),
)
publisher = Publisher(broker=broker, config=configuration)
async with redis, broker:
await publisher.enqueue(task(a=42, b="string"))
if __name__ == "__main__":
asyncio.run(main())
1 maintainer
Metadata
1 maintainer
Release files for aiotaskqueue 0.18.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| aiotaskqueue-0.18.0.tar.gz | 27.7 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| aiotaskqueue-0.18.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 69.6 kB
Release files / aiotaskqueue-0.18.0.tar.gz
| Download URL | aiotaskqueue-0.18.0.tar.gz |
|---|---|
| Size | 27.7 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
fdd726667a7545fec6896364e6f6af0a6ec025e5af154a0f1eeccb4eb158f10c
|
|
BLAKE2b-256 checksum How to use checksums |
bbe2216f292c975123343fcdf584b3160ec1b64d9e22eb6bcf06e329af800aa1
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.11.33 {"installer":{"name":"uv","version":"0.11.33","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
Release files / aiotaskqueue-0.18.0-py3-none-any.whl
| Download URL | aiotaskqueue-0.18.0-py3-none-any.whl |
|---|---|
| Size | 41.9 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
529bb421f69d64595ee51b8826e4dbdd70aa1327198812b9f65fdd0a59c94481
|
|
BLAKE2b-256 checksum How to use checksums |
303b1f5e898598d186e9b1d637e9ba7884e7d9f422d62273e7c7ee58dafa09fe
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.11.33 {"installer":{"name":"uv","version":"0.11.33","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
