I have just released version 0.7.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-7-0
RbFly 0.7.0 adds support for the deduplication of messages, fixes
various bugs, and improves the documentation.
This is the first release, where I decided to publish performance report
with the documentation. Performance testing is crucial part of RbFly design
and development.
At the moment, the combination of RbFly and RabbitMQ Streams broker can be
five times faster than other, similar solutions. This is for a specific
test scenario, of course.
The development status of RbFly library is changed to beta.
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. Writing stream offset reference.
4. Message deduplication.
5. Integration with AMQP 1.0 ecosystem at message format level.
Best regards,
Artur
--
https://mortgage.diy-labs.eu/