Library for operating messaging systems such as Apache Kafka and MQTT with the same API.
Project description
SINETStream python
Directory structure
- src/
- Implementation of SINETStream for Python
- tests/
- Unit test
- sample/
- Sample program
- plugins/
- broker/
- kafka/
- Kafka Plugin for SINETStream
- mqtt
- MQTT Plugin for SINETStream
- kafka/
- value_type/
- image/
- Plugin for handling image as message
- image/
- broker/
- README.md
Build procedure
Execute the following command to build the SINETStream TAR file.
$ python3 setup.py bdist_wheel
$ cd plugins/broker/kafka
$ python3 setup.py bdist_wheel
$ cd ../mqtt
$ python3 setup.py bdist_wheel
$ cd ../../value_type/image
$ python3 setup.py bdist_wheel
If the build is successful, the following WHL file will be created.
./dist/sinetstream-1.1.0-py3-none-any.whl
./plugins/broker/kafka/dist/sinetstream_kafka-1.1.0-py3-none-any.whl
./plugins/broker/mqtt/dist/sinetstream_mqtt-1.1.0-py3-none-any.whl
./plugins/value_type/image/dist/sinetstream_type_image-1.1.0-py3-none-any.whl
Install
You can also use the packages registered in pypi.
pip3 install --user sinetstream-kafka sinetstream-mqtt
If you want to handle image as message, please install the image plugin as follows.
pip3 install --user sinetstream-type-image
Dependent libraries
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
sinetstream-1.5.2.tar.gz
(12.1 kB
view hashes)
Built Distribution
Close
Hashes for sinetstream-1.5.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | bc858d5a80ebc4f0fa68de948df58eda657fd243220a7a4afe97a84784a64c04 |
|
MD5 | 2246ddb8d9f6c866ee129f99a2f7c0a9 |
|
BLAKE2b-256 | d2d7b5880aaea7a706a480107af391233a9308e2a72e29d65afd9b657309670d |