aioworkers-redis 0.8

Module for working with 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()