Python client library for Fluvio
Project description
Fluvio Client for Python
Documentation
Fluvio client uses pdoc to generate the client API documentation.
Example Usage
Producer
from fluvio import Fluvio
fluvio = Fluvio.connect()
producer = fluvio.topic_producer('my-topic')
producer.send_record("FOOBAR", 0)
Consumer
from fluvio import (Fluvio, Offset)
fluvio = Fluvio.connect()
consumer = fluvio.partition_consumer('my-topic-while', 0)
stream = consumer.stream(Offset.beginning())
for i in stream:
print(i.value_string())
Developer Notes
This project uses flapigen to genate the C static library and setuptools-rust to bundle it into a python package. For cross platform builds, cibuildwheel is used.
Running the tests locally require having already setup a fluvio locally or on fluvio cloud.
Add python unit tests in the tests
directory using the built in python
unittest
framework
You should probably stick to using make test
which will create the virtual
environment and install the
package in the site-packages in the venv directory. This makes sure that the
package is also packaged correctly.
If you'd like more rapid testing, once you've got the virtual environment
activated, python setup.py test
will compile the rust as a static library and
put it as fluvio/fluvio_python.cpython-39-x86_64-linux-gnu.so
. This filename
is dependent on the host OS and python version.
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 Distributions
Built Distributions
Hashes for fluvio-0.0.3-cp39-cp39-manylinux2010_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 37e69d58622916c210dca134d53d8cf439791edb784bc863b21423f93727a345 |
|
MD5 | 474aff6894a27fecf112fc308b9e4af4 |
|
BLAKE2b-256 | f8f1866cf66802889ca11c7e6c28b6b1b2a2d03a8bd51dc12738dc21eda23184 |
Hashes for fluvio-0.0.3-cp39-cp39-manylinux2010_i686.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 87b731c00d38a9b77a3133658b4b0468082dd887c732370b4db6ed50bb4a4dec |
|
MD5 | 2968f77b2fd6fb3c60a93923761009db |
|
BLAKE2b-256 | ed461c76a30b1b38d017ecc017a3cabcaeab841e67666986b1d82bc57358ce99 |
Hashes for fluvio-0.0.3-cp39-cp39-macosx_10_9_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 971de1cdf614a07362bc3ece33b1f8fe9afa503c70ea933f7e52b3ffc87bc92f |
|
MD5 | dccf80e19db60e4c0893b26d6d695be0 |
|
BLAKE2b-256 | 520f9213787f6468bf2012fe787eaa62036af549750432c9b007f8c41fd2dce0 |
Hashes for fluvio-0.0.3-cp38-cp38-manylinux2010_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ccb4fc1f67400d6cd0534b004d74467d09c113b225a50475b4c0057215490b63 |
|
MD5 | 0387f14657844fde8e9ef65f247689ca |
|
BLAKE2b-256 | 8a0d524f6a840164ff6786040036ce813c6d95f2e8acc1dbef2e9689907fe11e |
Hashes for fluvio-0.0.3-cp38-cp38-manylinux2010_i686.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 99962d446b5200fc9d34c94cbdbf00dfc872fc47abee0660be22a902daafa28a |
|
MD5 | 5f5534236853daa7ea8ccd7dbf3bf582 |
|
BLAKE2b-256 | d92d9e0e611ce5eeb11c362e94a83d833eee461e3747816064af734f7d3de9b5 |
Hashes for fluvio-0.0.3-cp38-cp38-macosx_10_9_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7e8fb8a4905d4914916e6f4c3608cdec7f8521a86a073883f86d9268545dee0e |
|
MD5 | 677775f9f585f3a2b0c46aaff00813d8 |
|
BLAKE2b-256 | 6376ef86f997d56583481bddc7d05c45bbca39402a9143860340a16315670097 |
Hashes for fluvio-0.0.3-cp37-cp37m-manylinux2010_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6ff66b976f27f2d66b282eaa8cec905be2510b54375db38decdee088cef9cab0 |
|
MD5 | 29d14562ae5649638d3e73b36bd20b4f |
|
BLAKE2b-256 | 2606a354f7ee1fe15354f8c0035c25e6a8260c880a2dd2220695f55273782a8a |
Hashes for fluvio-0.0.3-cp37-cp37m-manylinux2010_i686.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a082658dbfbd4e018f991b6d8400711449033941583765598aae9d0c6b963f84 |
|
MD5 | 8c59bfad5e1afffdefc50cd014ec86bc |
|
BLAKE2b-256 | faf88a914658be421f349a46b61d717a3345483391b5193b882d9a1b21881641 |
Hashes for fluvio-0.0.3-cp37-cp37m-macosx_10_9_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d111b1a12ea6fd0b25cff803c61a45b611519916efb75b2da3108228640c95ac |
|
MD5 | 68721a7e7fe8bb2c40e5da609ff6ac56 |
|
BLAKE2b-256 | 072d4246b244699e10e72e57dc274281101a4c35995d59db6a3131f5adeca74a |
Hashes for fluvio-0.0.3-cp36-cp36m-manylinux2010_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f1e69cf883184574415ca6f6651b6ad4fc29bd869765dc93fee28accd284cf09 |
|
MD5 | 0afec912d7f098a5e74a6ab9ca7c023f |
|
BLAKE2b-256 | 004a3d000e38537bec75553c4c6b5548e2034687bf269a1c9532622b2dff7b11 |
Hashes for fluvio-0.0.3-cp36-cp36m-manylinux2010_i686.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8604075bd4b323fcacb3f271c713d886270e503de3d7c3b63dcb3e9860979009 |
|
MD5 | 12309eb20b9c77d9b2aaa035617549e6 |
|
BLAKE2b-256 | 69446c461cff590ff0bbe5ffc8aab02c8fe1138d14edad493ff5ceffba01b60b |
Hashes for fluvio-0.0.3-cp36-cp36m-macosx_10_9_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ac04e3c48d1683ab631056b2107a2e912cd4d13360162c5984c7b0591a5a0fa9 |
|
MD5 | 92c59a94a6abc242567661a001f2da92 |
|
BLAKE2b-256 | 2750a37f82ebfb81eef9a7821226499bfb1c9ea27668e172bb34cb12d2c068da |