Async utilities for backend python services developed by Quantmind.
Documentation: fluid.quantmind.com
Source Code: github.com/quantmind/aio-fluid
Features
- Async workers — composable components with a managed start/stop lifecycle; the building block everything else is built on. See Workers.
- Task scheduler & consumer — declare tasks with a
@taskdecorator, schedule them withevery()or cron expressions, run them concurrently with priorities and concurrency limits, and offload CPU-bound work to subprocesses or Kubernetes Jobs. Backed by a pluggable broker (Redis by default). See Tasks. - Async Postgres CRUD — a typed CRUD layer over
asyncpgand SQLAlchemy, with pagination and schema migrations. See Database. - Event dispatchers — sync and async
Dispatchertypes for decoupling event sources from handlers. See Dispatchers. - HTTP client helpers — a unified async client wrapping
httpxandaiohttp. See HTTP Client. - CLI tooling — ready-made
click/richcommand-line interfaces for task managers and databases.
Installation
This is a python package you can install via pip:
pip install aio-fluid
To install all the dependencies:
pip install aio-fluid[cli, db, http, log, k8s]
this includes the following extra dependencies:
clifor the command line interface using click and richdbfor database support with asyncpg and sqlalchemyhttpfor http client support with httpx and aiohttplogfor JSON logging support with python-json-loggerk8sfor Kubernetes support for CPU bound tasks
Development
You can run the examples via
uv run python -m examples
We use uv as a development tool to run the examples and tests, but you can also use python directly if that's your preference.
License
This project is licensed under the BSD License - see the LICENSE file for details.
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file aio_fluid-2.4.3.tar.gz.
File metadata
- Download URL: aio_fluid-2.4.3.tar.gz
- Upload date:
- Size: 687.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.29 {"installer":{"name":"uv","version":"0.11.29","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}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
ef4f26437b5f38b0100b4c3ab2a614a80629d4e580910a31e7f695930b24c163
|
|
| MD5 |
ecb11637c547a145abd5dd88550ff7e7
|
|
| BLAKE2b-256 |
79e3ad3fc367fb88fbb0528e860a5f589b3a757685751408761e43382e971bca
|
File details
Details for the file aio_fluid-2.4.3-py3-none-any.whl.
File metadata
- Download URL: aio_fluid-2.4.3-py3-none-any.whl
- Upload date:
- Size: 71.1 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.29 {"installer":{"name":"uv","version":"0.11.29","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}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
1c464103d006d882a4cd22e9c8c11e61ef92cff6825e753ba71ab5e57e4e172f
|
|
| MD5 |
5b0ba57f299cc25a9e68b1f879e0893a
|
|
| BLAKE2b-256 |
3a35010a23243ca3a65eba7cd4aa13302845f441eefb3ffefd6b57e83025b75f
|
