No project description provided
Project description
Gufo Liftbridge
An asynchronous Python Liftbridge client
Documentation: https://docs.gufolabs.com/gufo_liftbridge/
Source Code: https://github.com/gufolabs/gufo_liftbridge/
Gufo Liftbridge is the Python asyncio Liftbridge client library. It hides complex cluster topology management handling tasks and the internals of the gRPC as well. Client offers following features:
- Publishing.
- Subscribing.
- Bulk publishing.
- Cursors manipulation.
- Cluster metadata fetching.
- Stream creating and destroying.
- Transparent data compression (own extension, may be not compatible with other clients).
Installing
pip install gufo_liftbridge
Publishing
from gufo.liftbridge.client import LiftbridgeClient
async def publish():
async with LiftbridgeClient(["127.0.0.1:9292"]) as client:
await client.publish(b"mybinarydata", stream="test", partition=0)
Subscribing
from gufo.liftbridge.client import LiftbridgeClient
async def subscribe():
async with LiftbridgeClient(["127.0.0.1:9292"]) as client:
async for msg in client.subscribe("test", partition=0):
print(f"{msg.offset}: {msg.value}")
Virtues
- Clean async API.
- High-performance.
- Full Python typing support.
- Editor completion.
- Well-tested, battle-proven code.
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
gufo_liftbridge-0.1.0.tar.gz
(26.7 kB
view hashes)
Built Distribution
Close
Hashes for gufo_liftbridge-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6a2c8e1de6239f4549de5be2dd2f9a860ea8c0b86b2d10c6e312edfbb776028d |
|
MD5 | 385d72292668ddedc5d3b341dbbf9826 |
|
BLAKE2b-256 | 22331d0813cc7452dbb8b28b14f268e30412c7c57fb3c8927668e434313c9e55 |