Persistent queues for Python AsyncIO.
Project description
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
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aiodiskqueue-0.1.0a4.tar.gz
(9.1 kB
view hashes)
Built Distribution
Close
Hashes for aiodiskqueue-0.1.0a4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 83175a24b7616f1fae681a4fa55f57284d9ec517c4dccd13024ef1d669b74873 |
|
MD5 | 24cc1d57dbd25898ebbb1b297bcd029c |
|
BLAKE2b-256 | 0cf2c1e72ce2196261e626745d06424ca5f0b1965e2bc42436f0313f9d15e6da |