Persistent queue for Python AsyncIO.
Project description
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
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.0a6.tar.gz
(9.9 kB
view hashes)
Built Distribution
Close
Hashes for aiodiskqueue-0.1.0a6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f2cb630bfcd9eed1e2ef38f68767cd5e6d34d9ab722ed97c84a98e50420af34f |
|
MD5 | fe88b91684774e3f0021f02891938749 |
|
BLAKE2b-256 | 5dbaf460eff99b877fcdd4c682766f4efea9bc117c2e1b39e56561e5ca54a43e |