シナリオ: ログ・分析へのストリーミング・データの送信

コネクタ・ハブを使用して、OCIストリーミング・サービスからログ・アナリティクスにストリーミング・データを送信する方法について学習します。ストリーミングは、大量のデータストリームをリアルタイムで取り込み、消費します。

必要なIAMポリシー

デフォルト・ポリシーによって、必要なアクセス権が提供されます。ストリーミング・ソースおよびログ・アナリティクス・ターゲットでコネクタを作成するためのワークフローには、ストリームを読み取るためのデフォルト・ポリシーとログ・アナリティクスに書き込むためのデフォルト・ポリシーが含まれます。ポリシーを初めて使用する場合は、ポリシーの開始および共通ポリシーを参照してください。

目標

このシナリオの目的は、ストリーム・データを分析することです。

このシナリオの設定

このシナリオの設定では、分析のためにログ・アナリティクスにストリームを移動するコネクタを作成します。

これらのタスクは、Oracle Cloud Infrastructureコンソール、CLIまたはAPIで完了できます。

コンソールの使用

ナビゲーション・メニューを開き、「アナリティクスとAI」をクリックします。「メッセージング」で、「コネクタ・ハブ」をクリックします。
コネクタを作成するコンパートメントを選択します。
「コネクタの作成」を選択します。
「コネクタの作成」ページで、ストリームをログ・アナリティクスに移動します:
1. コネクタ名を入力します。機密情報を入力しないでください。例: 「Metrics to Bucket」
2. 新しいコネクタを格納するリソース・コンパートメントを選択します。
3. 「コネクタの構成」で、ログ・データをメトリックに移動するソース・サービスおよびターゲット・サービスを選択します:
  - ソース: ストリーミング
  - ターゲット: ログ・アナリティクス
4. 「ソースの構成」で、ストリームを選択します:
  - コンパートメント: ストリームを含むコンパートメントを選択します。
  - ストリーム・プール: ストリームを含むストリーム・プールの名前を選択します。
  - ストリーム: データを受信するストリームの名前を選択します。
  - 読取り位置: コネクタの保存後に公開されたメッセージで読取りを開始するには、「最新」を選択します。
5. オプションのタスクをスキップします(Configure task)。
6. 「ターゲットの構成」で、ストリームの移動先のログ・グループおよびソースを選択します:
  - コンパートメント: ログ・グループを含むコンパートメントを選択します。
  - ログ・グループ: 必要なログ・グループを選択します。
  - ログ・ソース識別子: ログ・ソースを選択します。
ポリシーの作成(コネクタがソース、タスクおよびターゲット・サービスにアクセスするために必要)を求められた場合は、「作成」を選択します。
「作成」を選択します。

新しいコネクタは、選択したログ・グループおよびソースへのストリームの移動をただちに開始します。

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操作を使用します。

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>"
  }
}