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.8.0.tar.gz
(19.7 kB
view hashes)
Built Distribution
Close
Hashes for sinetstream-1.8.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | eae0b9a23c3dc8dcbadb74c6a68f99872eab0ccb4925614aa361711d8f69b36d |
|
MD5 | c7021c558ff318295cf1c584f03b4ab2 |
|
BLAKE2b-256 | a0c443433cfe356ca034b42692f039dcf6e8501c67d9c313252ecd0530b6bed1 |