Persistent queue for Python AsyncIO.
Project description
Persistent queue for Python AsyncIO.
Description
This library provides a persistent FIFO queue for Python AsyncIO:
Queue content is preserved after a by process restart
Feature parity with Python’s asyncio.Queue
Similar API to Python’s asyncio.Queue
Designed for durability and decent performance
Sane logging
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
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.0a9.tar.gz
(13.3 kB
view hashes)
Built Distribution
Close
Hashes for aiodiskqueue-0.1.0a9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 3e12056fb4bcc9f5c7b56e9d15a7b080324a434868fc9015946bf207ec908424 |
|
MD5 | 6f862c4a16dd43889f7d21c3bb7ef237 |
|
BLAKE2b-256 | f5019f5c1cf28a446cba2c5453e0449608c19de476d5e422fd9f45393bd82610 |