日本語

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
  • value_type/
    • image/
      • Plugin for handling image as message
• 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

• kafka-python
• mqtt client