RbFly 0.9.0 - a library for RabbitMQ Streams using Python asyncio

[Artur Wroblewski]

I have just released version 0.9.0 of RbFly. It is a library for RabbitMQ
Streams using Python asyncio

https://wrobell.dcmod.org/rbfly/
https://wrobell.dcmod.org/rbfly/changelog.html#ver-0-9-0

RbFly 0.9.0 adds support for RabbitMQ Streams filtering with Bloom filters.
It also improves reporting of errors of RabbitMQ Streams protocol.

The documentation for this release adds section about asynchronous
concurrency, and discusses use of parallelism in applications using RbFly
library.

The library is designed and implemented with the following qualities in
mind

1. Simple, flexible, and asynchronous Pythonic API with type annotations.
2. Use of AMQP 1.0 message format to enable interoperability between
clients.
3. Performance by implementing critical sections of code using Cython,
avoiding copying of data, and testing.
4. Auto reconnection to RabbitMQ broker with lazily created connection
objects.

RabbitMQ Streams features supported

1. Publishing single messages, or in batches, with confirmation.
2. Subscribing to a stream at a specific point in time, from a specific
offset, or using offset reference.
3. Stream message filtering.
4. Writing stream offset reference.
5. Message deduplication.
6. Integration with AMQP 1.0 ecosystem at message format level.

Best regards,

Artur

--
https://mortgage.diy-labs.eu/