Oracle Cloud Infrastructureドキュメント

OCIストリーミングで異常検出を起動します

異常検出を使用して、OCIストリーミング・サービスで異常を検出できます。

この組合せにより、ストリーミング・サービス・ストリームに入力データが有効になり、異常検出はこのデータ・ストリームで検出コールを実行し、その結果、出力データが別のストリームに配置されます。

OCIコネクタ・ハブ・サービスは、様々なサービスをまとめて接続するように設計されています。コネクタ・ハブを使用して異常検出、ファンクションおよびストリーミングを接続する場合、ストリーミング・データの異常を検出するソリューションを設計できます。ソリューションの設計は、次のとおりです:

  1. ストリーミングを使用して入力ストリームを指定します。

  2. ストリーミングを使用して出力ストリームを指定します。

  3. 異常検出を起動するファンクションをサービスとして作成します(FaaS)。

  4. 異常検出の結果をFaaSの出力として返す別のFaaSを作成します。

  5. 最後に、コネクタ・ハブを使用して、FaaS出力を出力ストリームに配置します。

ストリーム、ファンクションおよびコネクタを異常検出サービスに接続する方法を示します。

異常検出を使用したストリーミング・データの異常の検出

開始する前に、次のことが必要です:

  • このプロセスに使用できるトレーニング済モデル。サンプル・コードの次のプロパティを変更して、FaaSアプリケーションを作成します。

    • endpoint

    • model_id

    • stream_id

    • message_endpoint

    • partition_id

  • 異常検出サービス・ポリシーが設定されていることを確認します。

  • ファンクション・サービスが異常検出サービスをコールできるように、次のポリシーを設定します:

    1. ファンクションの動的グループを作成します:

      All {resource.compartment.id = <compartment_id>, resource.type = 'fnfunc' }
    2. 動的グループに次の権限を追加します:
      DEFINE dynamic-group AD_SERVICE_CALLING_FUNC as <function_dynamic_group>
ALLOW dynamic-group AD_SERVICE_CALLING_FUNC to use ai-service-anomaly-detection-model in compartment <compartment_name>
このソリューションを使用して、ストリーミング・データの異常を検出します:
  1. 様々な方法のいずれかを使用して、ストリーミング・サービスに入力ストリームと出力ストリームの両方を作成します。
  2. FaaSの作成に使用するファンクション・サービスでアプリケーションを作成します。

    アプリケーションがアクティブになったら、アプリケーションにファンクションを追加できます。

  3. リストからアプリケーション名をクリックします。
  4. 「開始」をクリックして、FaaSの作成を開始します。
  5. 「ローカル設定」をクリックします。
  6. 指示に従ってFaaSを設定し、これを使用して環境値をご使用のものに置き換えて起動します。

    続行する前に、FaaSがアクティブであることを確認します。

  7. (オプション)ログを使用してFaaSをデバッグする場合は、ロギングを有効にする必要があります。「ログ」をクリックし、「アクション」メニュー(アクション・メニュー)をクリックし、「ログの有効化」をクリックして次を指定します:
      • コンパートメント: ログを作成するコンパートメント。デフォルトでは、現在のコンパートメントです。
      • ログ・グループ: ログを作成するログ・グループ。既存のログ・グループを選択するか、次を選択します:
        • デフォルト・ログ・グループの自動作成。デフォルト・ログ・グループが存在しない場合は、デフォルト名で作成します。
        • 新規ログ・グループの作成。指定する名前と説明を使用してログ・グループを作成します。
      • ログ名: 新しいログの名前。デフォルトでは、<application-name>_invokeです。
      • ログの保持: ログ・データを保持する時間。
    2. 「ログの有効化」をクリックして、ログ(および指定した場合は新しいログ・グループ)を作成します。
  8. タスクを構成するには、「手動設定を使用」オプションを使用してコネクタ・ハブ・サービスでコネクタを作成します。
    ノート

    コネクタを作成するために必要なポリシーが構成されていない場合は、この作成ステップを使用して構成できます。

  9. 入力および出力ストリームを、作成したFaaSをタスクとして指定します。
  10. 「作成」をクリックして、セットアップを完了します。

これで、入力ストリームに送信されるメッセージはすべて異常検出サービスに渡されます。異常検出サービスからの結果は、出力ストリームに送信されます。