aiodiskqueue 0.1.0b1

Persistent queue for Python AsyncIO.

Persistent queue for Python AsyncIO.

Description

This library provides a persistent FIFO queue for Python AsyncIO:

• Queue content can persist a process restart

• Feature parity with Python’s asyncio.Queue

• Similar API to Python’s asyncio.Queue

• Sane logging

• Type hints

• Fully tested

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 this library directly from PyPI with the following command:

pip install aiodiskqueue