aioworkers-redis

Redis plugin for aioworkers.

Features

• Works on aioredis
• Queue based on RPUSH, BLPOP, LLEN, LRANGE
• ZQueue based on ZADD, ZRANGE, ZCARD, ZRANGE, 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

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()