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.3.0.tar.gz
(11.9 kB
view hashes)
Built Distribution
Close
Hashes for sinetstream-1.3.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dd76c7caa784bbd49b5b562dab8f551a1ed9227be181aea38575ef27317dbabc |
|
MD5 | 320c7af152884299e76b3abb99d63b28 |
|
BLAKE2b-256 | f196be10df9a64beefa7227117375eb6c2f8493fb1afee39698817e75626bccc |