ノート:

OCI REST APIコールを使用した、APIゲートウェイの背後にあるプライベートOCIストリーミングのトピックの使用

イントロダクション

Oracle Cloud Infrastructure (OCI) Streamingサービスは、大量のデータ・ストリームをリアルタイムで取り込んで消費するためのフルマネージド型のスケーラブルな耐久性のあるソリューションを提供します。パブリッシュ/サブスクライブ・メッセージング・モデルでデータが連続して順次生成および処理されるユースケースには、OCIストリーミングを使用します。

このシナリオでは、パブリックAPIゲートウェイを使用してアクセスを制御および保護するプライベートOCIストリーミングのトピックを公開および消費する必要があります。

目標

このチュートリアルでは、APIゲートウェイREST APIコールを使用したOCIストリーミングのトピックの使用方法を示します。

前提条件

タスク1: OCIストリーミングからの詳細の取得

  1. ストリームに移動してOCIDを書き留め、「メッセージング」の下の「アナリティクスとAI」をクリックし、「ストリーミング」をクリックしてストリームを選択します。

  2. OCIDおよびメッセージ・エンドポイントは、APIゲートウェイで必要になります。

    T1_2

タスク2: パブリックAPIゲートウェイの作成

タスク3: APIゲートウェイのデプロイメントの作成

  1. タスク2で作成したAPIゲートウェイを選択し、「デプロイメント」をクリックして、「デプロイメントの作成」をクリックします。

  2. ここで、your_ocid_for_streamを次のストリームOCIDに置き換えて接頭辞を作成し、publicTopicという名前を入力します。

    /20180418/streams/your_ocid_for_stream

    T3_1

  3. 「次」をクリックします。

    T3_2

  4. 「次」をクリックします。

  5. groupCursorsのルート1の作成: このチュートリアルのタスク2で収集したエンドポイントおよびストリームOCIDを使用してURLを作成し、URLを作成します。

    <streaming_endpoint>/20180418/streams/<stream_ocid>/groupCursors

    ノート: ストリームを消費するために、OCI REST API for Streamingでは2つのエンドポイントgroupCursorsおよびメッセージを使用し、これら2つのルートを作成する必要があります。次に、次に示すように、パス、メソッド、バックエンド・タイプなどの必要な情報を指定します:

    T3_2

  6. +Another routeをクリックし、messagesにRoute 2を追加します。同じURLを使用するが、末尾に異なるエンドポイントを/messagesとして使用します。

    T3_2

  7. publicTopicに移動し、APIゲートウェイのエンドポイントをメモします。

    T3_2

タスク4: ストリーミングでのテスト・メッセージの生成

タスク5: APIゲートウェイの背後にあるREST APIを介したOCIストリーミングの使用

  1. サンプルPythonの消費コードconsume_rest_api_oci_lab.pyをダウンロードします。

  2. このチュートリアルですでに収集した値で示されているように、APIゲートウェイ・エンドポイントおよびストリームOCIDの値を変更します。

    T4_1

  3. Pythonコードを実行して、動作していることを確認します。

    python3 consume_rest_api_oci_lab.py

    T4_2

謝辞

その他の学習リソース

docs.oracle.com/learnで他のラボをご覧いただくか、Oracle Learning YouTubeチャネルでより無料のラーニング・コンテンツにアクセスしてください。また、education.oracle.com/learning-explorerにアクセスして、Oracle Learning Explorerになります。

製品ドキュメントについては、Oracle Help Centerを参照してください。