sinetstream 1.0.0

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

SINETStream python

ファイル構成

• src/
  • Python版SINETStreamの実装
• tests/
  • ユニットテスト
• sample/
  • サンプルプログラム
• plugins/
  • kafka/
    • Python版SINETStreamのKafka固有部分
  • mqtt
    • Python版SINETStreamのMQTT固有部分
• README.md

ビルド手順

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

$ python3 setup.py bdist_wheel
$ cd plugins/kafka
$ python3 setup.py bdist_wheel
$ cd ../mqtt
$ python3 setup.py bdist_wheel
$ cd ../..

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

./dist/sinetstream-1.0.0-py3-none-any.whl
./plugins/kafka/dist/sinetstream_kafka-1.0.0-py3-none-any.whl
./plugins/mqtt/dist/sinetstream_mqtt-1.0.0-py3-none-any.whl

インストール

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

pip3 install --user sinetstream-kafka sinetstream-mqtt

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

• kafka-python
• mqtt client