RbFly is a library for RabbitMQ Streams using Python asyncio
- https://www.rabbitmq.com/streams.html
- https://docs.python.org/3/library/asyncio.html
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
RabbitMQ Streams 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.
RbFly supports many RabbitMQ Streams broker features
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.
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.
Raw data
{
"_id": null,
"home_page": "https://wrobell.dcmod.org/rbfly/",
"name": "rbfly",
"maintainer": null,
"docs_url": null,
"requires_python": ">=3.11",
"maintainer_email": null,
"keywords": null,
"author": "Artur Wroblewski",
"author_email": "wrobell@riseup.net",
"download_url": "https://files.pythonhosted.org/packages/72/4c/116c6017782ba80f7a56d56cac16b65c3d36c711677add9b1d92b7bcc81d/rbfly-0.10.0.tar.gz",
"platform": null,
"description": "RbFly is a library for RabbitMQ Streams using Python asyncio\n\n- https://www.rabbitmq.com/streams.html\n- https://docs.python.org/3/library/asyncio.html\n\nThe library is designed and implemented with the following qualities in\nmind\n\n1. Simple, flexible, and asynchronous Pythonic API with type annotations.\n2. Use of AMQP 1.0 message format to enable interoperability between\n RabbitMQ Streams clients.\n3. Performance by implementing critical sections of code using Cython,\n avoiding copying of data, and testing.\n4. Auto reconnection to RabbitMQ broker with lazily created connection\n objects.\n\nRbFly supports many RabbitMQ Streams broker features\n\n1. Publishing single messages, or in batches, with confirmation.\n2. Subscribing to a stream at a specific point in time, from a specific\n offset, or using offset reference.\n3. Stream message filtering.\n4. Writing stream offset reference.\n5. Message deduplication.\n6. Integration with AMQP 1.0 ecosystem at message format level.\n\nRbFly library is licensed under terms of GPL license, version 3, see\nCOPYING file for details. As stated in the license, there is no warranty,\nso any usage is on your own risk.\n",
"bugtrack_url": null,
"license": "GPLv3+",
"summary": "RbFly - a library for RabbitMQ Streams using Python asyncio",
"version": "0.10.0",
"project_urls": {
"Bug tracker": "https://gitlab.com/wrobell/rbfly/issues",
"Homepage": "https://wrobell.dcmod.org/rbfly/",
"Source Code": "https://gitlab.com/wrobell/rbfly"
},
"split_keywords": [],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "724c116c6017782ba80f7a56d56cac16b65c3d36c711677add9b1d92b7bcc81d",
"md5": "1a0254e034ca18b45c3fe1b531bed0c1",
"sha256": "c65dc65853a9435293a0f3961573b7a4953a8adaa032a8f620abaf8f49d22e05"
},
"downloads": -1,
"filename": "rbfly-0.10.0.tar.gz",
"has_sig": false,
"md5_digest": "1a0254e034ca18b45c3fe1b531bed0c1",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.11",
"size": 576807,
"upload_time": "2024-10-17T18:27:06",
"upload_time_iso_8601": "2024-10-17T18:27:06.979755Z",
"url": "https://files.pythonhosted.org/packages/72/4c/116c6017782ba80f7a56d56cac16b65c3d36c711677add9b1d92b7bcc81d/rbfly-0.10.0.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-10-17 18:27:06",
"github": false,
"gitlab": true,
"bitbucket": false,
"codeberg": false,
"gitlab_user": "wrobell",
"gitlab_project": "rbfly",
"lcname": "rbfly"
}
JSON