sinetstream 1.1.0

Library for operating messaging systems such as Apache Kafka and MQTT with the same API.

English

SINETStream python

ファイル構成

• src/
  • Python版SINETStreamの実装
• tests/
  • ユニットテスト
• sample/
  • サンプルプログラム
• plugins/
  • broker/
    • kafka/
      • SINETStreamのKafkaプラグイン
    • mqtt
      • SINETStreamのMQTTプラグイン
  • value_type/
    • image/
      • 画像をメッセージとして扱うためのプラグイン
• README.md

ビルド手順

次のコマンドを実行するとSINETStreamのTARファイルがビルドされる。

$ 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

ビルドが成功すると以下のwheel ファイルが作成される。

./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

インストール

pypiに登録してあるパッケージを利用することもできる。

pip3 install --user sinetstream-kafka sinetstream-mqtt

画像タイプのメッセージを扱いたい場合は、imageプラグインをインストールする。

pip3 install --user sinetstream-type-image

依存関係にあるライブラリ

• kafka-python
• mqtt client