RbFly is a library for RabbitMQ Streams using Python asyncio
The library is designed and implemented with the following qualities in mind
Simple, flexible, and asynchronous Pythonic API with type annotations.
Use of AMQP 1.0 message format to enable interoperability between RabbitMQ Streams clients.
Performance by implementing critical sections of code using Cython, avoiding copying of data, and testing.
Auto reconnection to RabbitMQ broker with lazily created connection objects.
RbFly supports many RabbitMQ Streams broker features
Publishing single messages, or in batches, with confirmation.
Subscribing to a stream at a specific point in time, from a specific offset, or using offset reference.
Stream message filtering.
Writing stream offset reference.
Message deduplication.
Integration with AMQP 1.0 ecosystem at message format level.
TLS and authentication with X.509 certificates.
RbFly library is licensed under terms of GPL license, version 3, see COPYING file for details. As stated in the license, there is no warranty, so any usage is on your own risk.
1 maintainer
Release files for rbfly 0.11.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| rbfly-0.11.1.tar.gz | 650.2 kB | Details |
Release files / rbfly-0.11.1.tar.gz
| Download URL | rbfly-0.11.1.tar.gz |
|---|---|
| Size | 650.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
2ef2f7f4cd2b8c36b094dd1397a01e8d1c24beeac68e46d2437448663e5f9d8a
|
|
BLAKE2b-256 checksum How to use checksums |
382ab0b73c71ea806730f6c990a7ba0388316a1b5af23efee8652182ba1f84d2
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/6.2.0 CPython/3.14.4
|
