Library for operating messaging systems such as Apache Kafka and MQTT with the same API.
Project description
SINETStream python
ファイル構成
- src/
- Python版SINETStreamの実装
- tests/
- ユニットテスト
- sample/
- サンプルプログラム
- plugins/
- broker/
- kafka/
- SINETStreamのKafkaプラグイン
- mqtt
- SINETStreamのMQTTプラグイン
- kafka/
- value_type/
- image/
- 画像をメッセージとして扱うためのプラグイン
- image/
- broker/
- 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
依存関係にあるライブラリ
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.1.0.tar.gz
(10.5 kB
view hashes)
Built Distribution
Close
Hashes for sinetstream-1.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 3a01f62cd6b0ef1bbe299f806c1bf924d7408034217a570d867c692b99d1953a |
|
MD5 | 5c8e8aa9cbc4e5171b0a77572735810c |
|
BLAKE2b-256 | 9c008bb9bcf5212171ef507febea572026e7c60a323c7bcc7088516e278fcf76 |