ノート:
- このチュートリアルではOracle Cloudへのアクセスが必要です。無料アカウントにサインアップするには、Oracle Cloud Infrastructure Free Tierの開始を参照してください。
- Oracle Cloud Infrastructure資格証明、テナンシおよびコンパートメントの値の例を使用します。演習を完了する場合は、これらの値をクラウド環境に固有の値に置き換えてください。
ThingsBoardとOCIストリーミング・サービスの統合
イントロダクション
ThingsBoardは、データ収集、処理、視覚化およびデバイス管理のためのオープンソースのIoTプラットフォームです。このチュートリアルでは、ThingsBoardをOracle Cloud Infrastructure (OCI)ストリーミング・サービスと統合するために実行する必要があるステップを示します。この方法では、データをデータベースに格納し、分析を実行し、関数を使用してこの情報を変更および処理できます。
目的
- OCIから必要な情報を収集します。
- ThingsBoardルール・チェーンでKafkaノードを構成します。
前提条件
- OCIストリーミング、Kafkaの基本知識。
- ThingsBoardルール・チェーンの理解。
- ストリーミング・リソースの作成およびアクセスを可能にするユーザー権限。
- マシンにインストールされているThingsBoard。Community Editionのインストール・ステップは、ここにあります。
タスク1: Kafkaサーバーとの統合に必要なOCI蒸発パラメータの収集
-
OCIストリームがまだ作成されていない場合は、これらのステップに従って、コンソールから新しいストリームを作成できます。
-
既存のStreamの場合は、次の情報に注意してください。
-
ナビゲーション・メニューを開き、「アナリティクスとAI」をクリックします。
-
「メッセージング」で、「ストリーミング」をクリックします。
-
「ストリーム」タブで、既存のストリームを開き、ストリーム名を書き留めます(例: thingsboard_stream)。
-
「ストリーム・プール」リンクをクリックします(例: thingsboard_stream_pool)。

-
左側のメニューで、「Kafka接続設定」に移動し、次の情報をコピーします:
-
ブートストラップ・サーバー: たとえば、cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
-
SASL接続文字列: たとえば、*org.apache.kafka.common.security.plain.PlainLoginModule required username="
/oracleidentitycloudservice/ / " password="AUTH_TOKEN";* -
セキュリティープロトコル: SASL_SSL
-
セキュリティ・メカニズム: PLAIN

-
-
画面の右上隅にあるプロファイル・アイコンをクリックします。「ユーザー・プロファイル」で、「認証トークン」をクリックし、トークンを生成して値AUTH_TOKENをコピーします(例: xmo?(cv<abcd....)。既存のトークンを使用することもできます。
-
タスク2: Kafkaルール・ノードの構成

-
アクション・パネルからKafkaルール・ノードをドラッグします。タスク1に記載されている情報を使用して、Kafkaルールを構成します。
-
名前: 例- ThingsBoard2OCIStream
-
トピック・パターン: "StreamName"、例- thingsdemo-s0
-
ブートストラップ・サーバー: "ブートストラップ・サーバー"、例- cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
-
その他のプロパティ: 「追加」をクリックし、次のキー・ペアを追加します。
-
security.protocol: セキュリティ・プロトコルSASL_SSL
-
sasl.mechanism: セキュリティ・メカニズムのPLAIN
-
ssl.endpoint.identification.algorithm: https
-
SASL.jaas.config: <SASL接続文字列:>。例: - *org.apache.kafka.common.security.plain.PlainLoginModule required username="
/ / " password="AUTH_TOKEN";* (AUTH_TOKENは、タスク1でコピーされた値と置き換えます)
-
-
注:
文字列sasl.jaas.configが機能しない場合、テナンシのOracle Identity Cloud Serviceに問題がある可能性があるため、ローカル・ユーザーから同じものを使用してください。
オプション: トラブルシューティングのためにデバッグ・モードを確認することもできます。
必要な値を更新したら、「チェックマーク」ボタンをクリックして構成を保存します。
タスク3: ルール・チェーンの構成

-
時系列を保存ブロックとkafkaブロックの間にリンクをドラッグして、保存した時系列をOCIストリームに転送できるようにします。
-
リンク・ラベルに「成功」と入力します。
-
「チェックマーク」ボタンをクリックして構成を保存します。
-
OCIコンソールにログインし、ストリームをチェックして、データが受信されていることを確認します。「メッセージのロード」をクリックします。

OCIストリーミングで情報を受信したら、OCIサービス・コネクタ・サービスを使用して、OCIストレージ、OCIファンクションなどの他のサービスに転送できます。
関連リンク
謝辞
- Adina Nicolescu (シニア・クラウド・エンジニア)、Guido Alejandro Ferreyra (主席クラウド・アーキテクト)
その他の学習リソース
docs.oracle.com/learnで他のラボをご覧いただくか、Oracle Learning YouTubeチャネルでより無料のラーニング・コンテンツにアクセスしてください。また、education.oracle.com/learning-explorerにアクセスして、Oracle Learning Explorerになります。
製品ドキュメントについては、Oracle Help Centerを参照してください。
Integrate ThingsBoard with OCI Streaming Services
F79939-01
April 2023
Copyright © 2023, Oracle and/or its affiliates.