Skip to content

Latest commit

 

History

History
42 lines (23 loc) · 582 Bytes

File metadata and controls

42 lines (23 loc) · 582 Bytes

async_redis_queue

An asynchronous Redis Queue implemented using asyncio

installation

$ pip install async_redis_queue

use

import asyncio
from async_redis_queue import create_async_redis_queue, AsyncRedisQueue


async def test1():
    q = await AsyncRedisQueue.from_cls_async('<queue-name>')
    return await q.get()

async def test2():
    q = await create_async_redis_queue('<queue-name>')
    await q.put('test')

loop = asyncio.get_event_loop()
loop.run_until_complete(test())
  • Free software: MIT license

Features

  • TODO