SINETStream は、Apache Kafka や MQTT Broker などの多様なメッセージングシステムに対し、以下の操作を統一的に行う機能を提供するラッパーライブラリである。
- ブローカーへの接続
- ブローカーからの切断
- ブローカーへのメッセージ送信
- ブローカーからのメッセージ受信
SINETStream は現在、バックエンドのメッセージングシステムとして Apache Kafka と MQTT Broker をサポートしている。 他のメッセージングシステムをサポートできるよう、バックエンドはプラグインとして拡張可能になっている。
SINETStream は Python API と Java API を提供している。
| 用語 | 意味 |
|---|---|
| Reader | メッセージを受信するプログラム |
| Writer | メッセージを送信するプログラム |
| ブローカー | Writerが送信したメッセージをReaderに中継するプログラム |
| トピック | メッセージを送受信するときの論理的なチャンネル |