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.0a8.tar.gz
(11.9 kB
view hashes)
Built Distribution
Close
Hashes for aiodiskqueue-0.1.0a8-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8806342098b0b6f5933b18a4351761081603f5da498d6e67b16e5dab4c1604c5 |
|
MD5 | 9e0309413479ed8d92eceb9be4269c47 |
|
BLAKE2b-256 | dce30921b18e675a5385a5c612b70bc7f7c74b3f97455e8332047760e50f25e5 |