aiodiskqueue 0.1.0a6

Persistent queue for Python AsyncIO.

Persistent queue for Python AsyncIO.

Description

This library provides a persistent queue for Python AsyncIO.

It has an API similar to the standard asyncio.Queue, but items in the queue will persists between process restarts.

Usage

Here is a basic example on how to use the queue:

import asyncio
from aiodiskqueue import Queue

async def main():
    q = Queue("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