Pravega client
Project description
Pravega Python client.
This project provides a way to interact with Pravega using Python client.
Pravega is an open source distributed storage service implementing Streams. It offers Stream as the main primitive for the foundation of reliable storage systems: a high-performance, durable, elastic, and unlimited append-only byte stream with strict ordering and consistency.
This project supports interaction with Pravega for Python versions 3.8+. For a quick tutorial on the Python bindings visit the book.
Also check out the Pravega Python client API documents.
Install
The client library can be installed using pip.
pip install pravega
The users can also choose to generate the bindings using the commands specified at PythonBinding .
Example
Write events
import pravega_client
# assuming Pravega controller is listening at 127.0.0.1:9090
stream_manager = pravega_client.StreamManager("tcp://127.0.0.1:9090")
scope_result = stream_manager.create_scope("scope_foo")
self.assertEqual(True, scope_result, "Scope creation status")
stream_result = stream_manager.create_stream("scope_foo", "stream_bar", 1) # initially stream contains 1 segment
self.assertEqual(True, stream_result, "Stream creation status")
writer = stream_manager.create_writer("scope_foo","stream_bar")
writer.write_event("hello world")
Read events
import pravega_client
# assuming Pravega controller is listening at 127.0.0.1:9090
stream_manager = pravega_client.StreamManager("tcp://127.0.0.1:9090")
reader_group = stream_manager.create_reader_group("my_reader_group", "scope_foo", "stream_bar")
reader = reader_group.create_reader("my_reader");
# acquire a segment slice to read
slice = await reader.get_segment_slice_async()
for event in slice:
print(event.data())
# after calling release segment, data in this segment slice will not be read again by
# readers in the same reader group.
reader.release_segment(slice)
# remember to mark the finished reader as offline.
reader.reader_offline()
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 saipravega-0.3.4-cp311-none-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | add0283c6d86c91ec0e29663a104287f70588bbd29b4e2eddfbedfb44c1e2d68 |
|
MD5 | 755d884421c6f37b2706e4af807b139c |
|
BLAKE2b-256 | 52afd77b458b6a06861e5cec30d166c4ef73e767a66d3c416833f87da32094da |
Hashes for saipravega-0.3.4-cp311-cp311-manylinux_2_35_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1e75f27b764cde6e5a3960d8b74b3a14a895aeb706b23e3782024352a01caa97 |
|
MD5 | 16bc80c854c07490d1f4566c737bfdab |
|
BLAKE2b-256 | fe621658eb0e149a785c8eef58a9ced49311d2e5869dbe56142d22efab19db2d |
Hashes for saipravega-0.3.4-cp311-cp311-macosx_10_7_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d8f291059cf4fd799b0305e2c4c6232ff9e1edbbda70615120df9ded9ae9bf34 |
|
MD5 | cd6eee0780f2d976b2e646c6ecefa6f2 |
|
BLAKE2b-256 | 8b7ce8d420df3785ee7bf486fc39ee3760e0e38ad6c286bae8524850dc271467 |
Hashes for saipravega-0.3.4-cp310-none-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dc25c5dc66a65d6490e6a4b6a6cb2498267d28e6cd8dbf9d38f34598e5d7cce1 |
|
MD5 | 795006fe8ae63af9aef3429a2ba2bddf |
|
BLAKE2b-256 | 52d2feb7fc1b23d9dfde8a3f0e97f985370f964dd78c27c29bbec2c59722ff55 |
Hashes for saipravega-0.3.4-cp310-cp310-manylinux_2_35_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 59725707b5c349b07cfe8692693ac277e4893e7e1e785777f5106598a4ec6024 |
|
MD5 | 7ad648afa1f7c2f0a6455b974636139f |
|
BLAKE2b-256 | 0ba64615427478bbbeab9f22fe25f619bc39cdaaac756a2c3564622a2d80c655 |
Hashes for saipravega-0.3.4-cp310-cp310-manylinux_2_31_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b1ab4971cb879ef3421167f3398f8ea5969330d59a47483b5cabea5c6baf4a34 |
|
MD5 | af27c5738f1567d52a688975c7c3d3cd |
|
BLAKE2b-256 | d5f58ae9deec28bdceee40cecff405a47e63cd14c701cfde9b4d07515ca14985 |
Hashes for saipravega-0.3.4-cp310-cp310-macosx_10_7_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 0da4c4e0765b04b3b8c57dd7081376f5a24821d299926f32866d83e2f4680931 |
|
MD5 | c01f9d83c8873e456866c6ef28ecda1b |
|
BLAKE2b-256 | 5f7ff00412941722bc7cd685924159eff814eba359a88940f8cfc0d53a821bd7 |
Hashes for saipravega-0.3.4-cp39-none-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | bc5d5c154408ca58181daceee91d1fff5f53f442533d7567a4748056eb559bcc |
|
MD5 | ad7fca59d37a741c4758e9e6fca10c73 |
|
BLAKE2b-256 | c6d0deb79ab7bfa34ce5862ffe017b24705d557190525f627b17c8130180bb82 |
Hashes for saipravega-0.3.4-cp39-cp39-manylinux_2_35_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4fd3404198c5844cabfb52e3196e6003bf22b9aa14dad8e2a66b397f424d8a97 |
|
MD5 | 4fccc9925542284fa675bcf8b59108c3 |
|
BLAKE2b-256 | fab93cb1570c78633c0e8a8d71e6ffc6748168ce49430812bc3837acab783bcb |
Hashes for saipravega-0.3.4-cp39-cp39-manylinux_2_31_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 0438d29b043478ed6f6bbbe670d5fea948b5f1effe42b8f450537014f3a92c9f |
|
MD5 | f23b8b17db4a05881d353de6d3a0f9d4 |
|
BLAKE2b-256 | 2e0b497f31f7110f637889b1b1ecb6a54e03166026c13601a90e50b7c45a485e |
Hashes for saipravega-0.3.4-cp39-cp39-macosx_10_7_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d6c633faecaaa5cad88153a63309918956b067e099c55fbf008fd52aa7d0b8e6 |
|
MD5 | 712d911234054b43a3456eedb7824e06 |
|
BLAKE2b-256 | 3b16f3daec80bc7bffafe28a25162dddf147fcb8bccf21b82ecffc6126322709 |
Hashes for saipravega-0.3.4-cp38-none-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b8ae9d9e15df0117112bf8316a570be8ed644543254dc0f0299dac43e9b56474 |
|
MD5 | ebaf6f6cd97f5efe0a3fda13bb90df1e |
|
BLAKE2b-256 | 276cb7a4eee1a854243c2e41f176eda6e96918de316d252909bbcce7c0e33804 |
Hashes for saipravega-0.3.4-cp38-cp38-manylinux_2_35_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 899c70aa4f6fbe79e7e9a99e1a35724efeaae4ea9f0949cf600147a03f4867cc |
|
MD5 | 30b33aa6da4591f8fef0ddb876d7a6f9 |
|
BLAKE2b-256 | 95071b144556ce71b65994003981533a38296173a79531f7852589ab3a7c6d20 |
Hashes for saipravega-0.3.4-cp38-cp38-manylinux_2_31_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 39d0e96bf2fc445fed841bb23dd7b602804565e60f1d384c15d6f134bea497d3 |
|
MD5 | 690f5bbf4ae36a56afa9fb3cfddd036a |
|
BLAKE2b-256 | ff5b7123b147d43f94be918d21255da9ce652468ce482444b97b91b0d953c67c |
Hashes for saipravega-0.3.4-cp38-cp38-macosx_10_7_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e71a2b48440cad1857e2a73f7f402e63d37d9e256a942c235b2f601867948b68 |
|
MD5 | 0d6fe3795b6146b5148ff02b3e9fae94 |
|
BLAKE2b-256 | ddb7fbe1a66ab0fdc47049024687cc5e3f739005ad3b20d40933aa1b64c68716 |
Hashes for saipravega-0.3.4-cp37-none-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | bc749c2b795faadd0e1486430f90e7a24daa552e06c1f54b71cd38d0bed3da2d |
|
MD5 | 383736ff615097edd9b2cba0b9ae15c2 |
|
BLAKE2b-256 | 7520c9eacdc4c387a8ec2e9a73d5d3aaf34ed7b4a7671755938a70bd97f10f5d |
Hashes for saipravega-0.3.4-cp37-cp37m-manylinux_2_35_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | df84f629030a38f9ff4223b11af8f692ad964d394c34ada9f839dfc12e89fbcb |
|
MD5 | 80c1df3f71758876d79814f7d4fcae1f |
|
BLAKE2b-256 | 0c18a76918c613f83daa7a82e898c0ddd4c7bf577b7159aeb86b81d18810d9ed |
Hashes for saipravega-0.3.4-cp37-cp37m-manylinux_2_31_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f7492a0cd7e2e62aecb01756b4cf1ab914384eed7bc87ca144c015d9741c0b60 |
|
MD5 | a89e1a1e783a4e0885239214182037be |
|
BLAKE2b-256 | 2d36da88a2334f688716ceb077a8c1d9d43bbfc8551e7d54dba2ac4c6e400567 |
Hashes for saipravega-0.3.4-cp37-cp37m-macosx_10_7_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 99ad682fd69c2b10f44c3dfd051aa9206a757ebc1f84175bb7f050fe08a9b0b8 |
|
MD5 | fd513f99ceb5993d6a7478e7d1ab22e8 |
|
BLAKE2b-256 | dccd4700ebb90470f343e0cc8e0fd9fed485c22ac476df7efd2bf92d9c8f7f3c |