ストリームへのテスト・メッセージの公開

ストリームが機能していることを確認するために、ストリーミング・サービスのストリームにテスト・メッセージを出力(公開)します。

CLI、APIまたはSDKを使用してストリームを移入します。メッセージを公開するための要件および推奨事項については、メッセージの公開を参照してください。SDKを使用してメッセージを公開するには、ストリーミングの開発者ガイドを参照してください。

1. 「ストリーム」リスト・ページで、操作するストリームを選択します。リスト・ページまたはストリームの検索に関するヘルプが必要な場合は、ストリームのリストを参照してください。
2. 詳細ページで、「テスト・メッセージの生成」を選択します。
3. 「データ」ボックスに、公開するテキストのみのメッセージを入力します。
4. 「生産」を選択します。

テスト・メッセージをストリームに公開するには、oci streaming stream message putコマンドと必要なパラメータを使用します:

oci streaming stream message put --stream-id <stream_id> --messages <JSON_messages> --endpoint <messages_endpoint>

ヒント

有効なフォーマット済JSONとして--messagesの入力を指定します。JSONフォーマットの詳細は、複合入力の受渡しおよび複合入力のためのJSONファイルの使用を参照してください。

たとえば、file.txtには、適切にフォーマットされたJSONが含まれます。その値はBase64でエンコードされています:

[
  {
    "key": "a2V5MQ==",
    "value": "dmFsdWUx"
  },
  {
    "key": "a2V5Mg==",
    "value": "dmFsdWUy"
  }
]

--messagesパラメータは、その値としてファイルを使用します:

oci streaming stream message put --stream-id ocid1.stream.oc1.phx.exampleuniqueID --messages file://file.txt --endpoint https://cell-1.streaming.us-phoenix-1.oci.oraclecloud.com  
{
  "data": {
    "entries": [
      {
        "error": null,
        "error-message": null,
        "offset": 0,
        "partition": "0",
        "timestamp": "2020-11-03T21:35:03.837000+00:00"
      },
      {
        "error": null,
        "error-message": null,
        "offset": 1,
        "partition": "0",
        "timestamp": "2020-11-03T21:35:03.837000+00:00"
      }
    ],
    "failures": 0
  }
}

PutMessages操作を実行して、テスト・メッセージをストリームに公開します。

Oracle Cloud Infrastructureドキュメント

ストリームへのテスト・メッセージの公開