repid 0.1.1

Async Redis queue for Python.

repid

The repid package is an async Redis queue for Python, built around aioredis.

pip install repid

It can be easily used near to existing aioredis instances. Integration with other packages (such as fastapi) is quite simple too!

Usage

On producer side:

import repid
import asyncio
from aioredis import Redis

myredis = Redis(host="localhost", port=6379, db=0, decode_responses=True)
myrepid = repid.Repid(myredis)

async def main():
    await myrepid.enqueue("my_first_job")

asyncio.run(main())

On consumer side:

import repid
import asyncio
from aioredis import Redis

myredis = Redis(host="localhost", port=6379, db=0, decode_responses=True)
myworker = repid.Worker(myredis)

@myworker.actor()
async def my_first_job():
    return "Hello Repid!"

asyncio.run(myworker.run_forever())

It's important to specify decode_responses=True because repid relaies on parsed data.