aiodiskqueue 0.1.0a1

Persistent queues for Python AsyncIO.

Persistent queues for Python AsyncIO.

Description

This library for Python AsyncIO provides queues, which persist their content on disk. Their main advantage is that they their content will survive a normal process restart and potentially even a process crash.

Usage

Here is a basic example on how to use the queue

import asyncio
from aiodiskqueue import Queue

async def main():
    q = await Queue.create("example_queue.sqlite")
    await q.put("some item")
    item = await q.get()
    print(item)

asyncio.run(main())