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.2.0.tar.gz
(11.3 kB
view hashes)
Built Distribution
Close
Hashes for sinetstream-1.2.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 611f1fb4b84e2618c2c6c3249b88a080fa399bf67c71f12dfc336af2c01e12ce |
|
MD5 | 7ce0183e1047ded0ba54d13419f08474 |
|
BLAKE2b-256 | 04f6e5aed4474ccf7258fb176a8b9ac9cd08a5e5196753833c2344ef331c1cf9 |