aiodiskqueue 0.1.0a2

Persistent queues for Python AsyncIO.

Persistent queues for Python AsyncIO.

Description

This library provides a persistent queue for Python AsyncIO.

It’s main advantage is that it’s content will survive a normal process restart and potentially even a process crash.

Each queue is stored in it’s own SQLite database on disk to provide maximum isolation between queues. Using SQLite should also make the queue inherently process safe [needs confirmation].

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

Please see the examples folder for more usage examples.

Installation

You can install directly from PyPI with the following command:

pip install aiodiskqueue