aioworkers-redis

Redis plugin for aioworkers.

https://github.com/aioworkers/aioworkers-redis/workflows/Tests/badge.svg

https://img.shields.io/pypi/dm/aioworkers-redis.svg

Features

Works on redis-py
Queue based on RPUSH, BLPOP, LPOP, LLEN, LRANGE
ZQueue based on ZADD, ZRANGE, ZCARD, ZREM, EVAL
TimestampZQueue based ZQueue
Storage based on SET, GET
HashStorage based on HSET, HGET, HDEL, HMSET, HMGET, HGETALL
HyperLogLogStorage based on PFADD, PFMERGE, PFCOUNT
XQueue based on XADD, XREADGROUP

Usage

Add this to aioworkers config.yaml:

redis:
    cls: aioworkers_redis.base.Connector
    prefix: app
    connection:
        host: localhost
        port: 6379
        maxsize: 20
queue:
    cls: aioworkers_redis.queue.Queue
    connection: .redis
    format: json
    key: queue

You can work with redis queue like this:

await context.queue.put({'a': 1})
d = await context.queue.get()

Development

Check code:

hatch run lint:all

Format code:

hatch run lint:fmt

Run tests:

hatch run pytest

Run tests with coverage:

hatch run cov

Metadata

Release files for aioworkers-redis 0.9.0

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for aioworkers-redis 0.9.0
File	Size	Uploaded
aioworkers_redis-0.9.0.tar.gz	13.5 kB	Feb 13, 2025	Details

Built distribution (wheel)

Table of built distributions (wheels) for aioworkers-redis 0.9.0
File	Interpreter	ABI	Platform	Reset
aioworkers_redis-0.9.0-py3-none-any.whl 16.8 kB Feb 13, 2025	Python 3	none	any	Details

Total release size: 30.2 kB

Release files / aioworkers_redis-0.9.0.tar.gz

Download URL	aioworkers_redis-0.9.0.tar.gz
Size	13.5 kB
Tags	Source
SHA-256 checksum How to use checksums	`2421384eb3b12d0ec9a49d254656e17c378ef58a1db09a2379e27d841e85f839`
BLAKE2b-256 checksum How to use checksums	`cb7c7ce068bfb5b0ead1bc8b636032da8ab7bdabf9121b5dd70fa200b109a154`
Upload date	Feb 13, 2025
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`python-httpx/0.28.1`

Release files / aioworkers_redis-0.9.0-py3-none-any.whl

Download URL	aioworkers_redis-0.9.0-py3-none-any.whl
Size	16.8 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`89e5daa935d3c3753c674118868aa98bbe390333851a3facaa2fd79dc0324fd8`
BLAKE2b-256 checksum How to use checksums	`e33278b7cc6b21798042e8355826b3ddc34035da546312259c71082fbab23fa0`
Upload date	Feb 13, 2025
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`python-httpx/0.28.1`