No project description provided
This project has been archived.
The maintainers of this project have marked this project as archived. No new releases are expected.
Project description
Serialise/deserialise flatbuffers blobs from kafka. This currently deserialises https://github.com/ess-dmsc/python-streaming-data-types, but I am working to make it agnostic. Python bindings for the respective schema will need to be generated.
Usage
See saluki --help for all options.
Listen to a topic for updates
saluki listen mybroker:9092/mytopic - This will listen for updates for mytopic on mybroker.
Consume from a topic
saluki consume mybroker:9092/mytopic -p 1 -o 123456 -m 10 - This will print 9 messages before (and inclusively the offset specified) offset 123456 of mytopic on mybroker, in partition 1.
Use the -g flag to go the other way, ie. in the above example to consume 9 messages FROM offset 123456
Install
pip install saluki
Developer setup
pip install .[dev]
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file saluki-0.0.3.tar.gz.
File metadata
- Download URL: saluki-0.0.3.tar.gz
- Upload date:
- Size: 88.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.12.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
0cf1c5e14d2ca80b4a66d00fdb6d5e3aeebe64ce2a513c00b3992ff10dddf2ae
|
|
| MD5 |
c24c03ca110e186cd4663c25a4c014f4
|
|
| BLAKE2b-256 |
5c56facb0b14a7167b507a292b6698870a9ade67030ccf214aed31e6eafd2633
|
Provenance
The following attestation bundles were made for saluki-0.0.3.tar.gz:
Publisher:
python-publish.yml on ISISComputingGroup/saluki
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
saluki-0.0.3.tar.gz -
Subject digest:
0cf1c5e14d2ca80b4a66d00fdb6d5e3aeebe64ce2a513c00b3992ff10dddf2ae - Sigstore transparency entry: 255983507
- Sigstore integration time:
-
Permalink:
ISISComputingGroup/saluki@5a7fc1ea8c3aa18ded2c45f02f72888c991eed44 -
Branch / Tag:
refs/tags/0.0.3 - Owner: https://github.com/ISISComputingGroup
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
python-publish.yml@5a7fc1ea8c3aa18ded2c45f02f72888c991eed44 -
Trigger Event:
release
-
Statement type:
File details
Details for the file saluki-0.0.3-py3-none-any.whl.
File metadata
- Download URL: saluki-0.0.3-py3-none-any.whl
- Upload date:
- Size: 7.6 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.12.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
99778f373d1a20c738bc3fb9b32f9cb753a8eb4ecd59f40e547064c021bb18c9
|
|
| MD5 |
c52b753c61687c9e4bee56123e357ef3
|
|
| BLAKE2b-256 |
3a51b2da35cbe267553608e8b13d7c6c728238f15444433ea85bc38c744a8d80
|
Provenance
The following attestation bundles were made for saluki-0.0.3-py3-none-any.whl:
Publisher:
python-publish.yml on ISISComputingGroup/saluki
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
saluki-0.0.3-py3-none-any.whl -
Subject digest:
99778f373d1a20c738bc3fb9b32f9cb753a8eb4ecd59f40e547064c021bb18c9 - Sigstore transparency entry: 255983510
- Sigstore integration time:
-
Permalink:
ISISComputingGroup/saluki@5a7fc1ea8c3aa18ded2c45f02f72888c991eed44 -
Branch / Tag:
refs/tags/0.0.3 - Owner: https://github.com/ISISComputingGroup
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
python-publish.yml@5a7fc1ea8c3aa18ded2c45f02f72888c991eed44 -
Trigger Event:
release
-
Statement type:
