シナリオ: ログ・分析へのストリーミング・データの送信
コネクタ・ハブを使用して、OCIストリーミング・サービスからログ・アナリティクスにストリーミング・データを送信する方法について学習します。ストリーミングは、大量のデータストリームをリアルタイムで取り込み、消費します。
必要なIAMポリシー
デフォルト・ポリシーによって、必要なアクセス権が提供されます。ストリーミング・ソースおよびログ・アナリティクス・ターゲットでコネクタを作成するためのワークフローには、ストリームを読み取るためのデフォルト・ポリシーとログ・アナリティクスに書き込むためのデフォルト・ポリシーが含まれます。ポリシーを初めて使用する場合は、ポリシーの開始および共通ポリシーを参照してください。
目標
このシナリオの目的は、ストリーム・データを分析することです。
このシナリオの設定
このシナリオの設定では、分析のためにログ・アナリティクスにストリームを移動するコネクタを作成します。
これらのタスクは、Oracle Cloud Infrastructureコンソール、CLIまたはAPIで完了できます。
コンソールの使用
-
ナビゲーション・メニューを開き、「アナリティクスとAI」をクリックします。「メッセージング」で、「コネクタ・ハブ」をクリックします。
-
コネクタを作成するコンパートメントを選択します。
-
「コネクタの作成」をクリックします。
-
「コネクタの作成」ページで、ストリームをログ・アナリティクスに移動します:
- コネクタ名を入力します。機密情報を入力しないでください。例: 「Metrics to Bucket」
- 新しいコネクタを格納するリソース・コンパートメントを選択します。
- 「コネクタの構成」で、ログ・データをメトリックに移動するソース・サービスおよびターゲット・サービスを選択します:
- ソース: ストリーミング
- ターゲット: ログ・アナリティクス
- 「ソースの構成」で、ストリームを選択します:
-
コンパートメント: ストリームを含むコンパートメントを選択します。
-
ストリーム・プール: ストリームを含むストリーム・プールの名前を選択します。
-
ストリーム: データを受信するストリームの名前を選択します。
-
読取り位置: コネクタの保存後に公開されたメッセージで読取りを開始するには、「最新」を選択します。
-
- オプションのタスクをスキップします(Configure task)。
- 「ターゲットの構成」で、ストリームの移動先のログ・グループおよびソースを選択します:
-
ポリシー(コネクタがソース、タスクおよびターゲット・サービスにアクセスするために必要)を作成するように要求された場合は、「作成」をクリックします。
-
「作成」をクリックします。
新しいコネクタは、選択したログ・グループおよびソースへのストリームの移動をただちに開始します。
CLIの使用
-
コネクタのストリーミング・ソースを定義します:
source.json
という名前のファイルを保存します。source.jsonファイルの例{ "kind": "streaming", "streamId": "<stream_OCID>", "cursor" : { "kind": "LATEST" } }
-
コネクタのオブジェクト・ストレージ・ターゲットを定義します:
target.json
という名前のファイルを保存します。target.jsonファイルの例{ "kind": "loggingAnalytics", "logGroupId": "<log_group_OCID>", "logSourceIdentifier": "<log_source_name>" }
oci sch service-connector createコマンドを使用して、コネクタを作成します:
コネクタを作成するためのコマンドの例oci sch service-connector create --compartment-id <compartment_OCID> --display-name "Stream to Logging Analytics" --source file://source.json --target file://target.json
CLIコマンドのパラメータおよび値の完全なリストは、CLIコマンド・リファレンスを参照してください。
トラブルシューティングのヘルプは、コネクタのトラブルシューティングおよび通知のトラブルシューティングを参照してください。
CLIコマンドのフラグおよび変数オプションの完全なリストは、コマンドライン・リファレンスを参照してください。
トラブルシューティングのヘルプは、コネクタのトラブルシューティングおよび通知のトラブルシューティングを参照してください。
APIの使用
コネクタを作成するには、CreateServiceConnector操作を使用します。
POST /20200909/serviceConnectors
Host: service-connector-hub.us-phoenix-1.oraclecloud.com
<authorization and other headers>
{
"compartmentId": "<compartment_OCID>",
"displayName": "Stream to Logging Analytics",
"source": {
"kind": "streaming",
"streamId": "<stream_OCID>",
"cursor" : {
"kind": "LATEST"
}
},
"target": {
"kind": "loggingAnalytics",
"logGroupId": "<log_group_OCID>",
"logSourceIdentifier": "<log_source_name>"
}
}
トラブルシューティングのヘルプは、コネクタのトラブルシューティングおよび通知のトラブルシューティングを参照してください。