メッセージの取得(読取り)

指定されたカーソルを使用して、ストリーミング・サービスのストリームからメッセージを取得(または読取り)します。メッセージは、ストリームにパブリッシュされるBase64でエンコードされたメッセージです。

メッセージを取得するためのコンシューマ・グループおよび個々のコンシューマの詳細は、コンシューマ・グループの使用および個々のコンシューマの使用を参照してください。

このタスクはコンソールを使用して実行できません。

ストリームからメッセージを取得するには、oci streaming stream message getコマンドおよび必要なパラメータを使用します:

oci streaming stream message get --stream-id <stream_OCID> --cursor <cursor> --endpoint <messages_endpoint>

メッセージを取得する最初のリクエストでは、カーソルの作成時に返された値を使用する必要があります。後続の各リクエストでは、前のレスポンスで返されたopc-next-cursor値を使用する必要があります。

例:

oci streaming stream message get --stream-id ocid1.stream.oc1.phx.exampleuniqueID --cursor examplecursorvalue --endpoint https://cell-1.streaming.us-phoenix-1.oci.oraclecloud.com
{
  "data": [
    {
      "key": "a2V5MQ==",
      "offset": 0,
      "partition": "0",
      "stream": "MyStream",
      "timestamp": "2020-11-03T21:52:58.470000+00:00",
      "value": "dmFsdWUx"
    },
    {
      "key": "a2V5Mg==",
      "offset": 1,
      "partition": "0",
      "stream": "MyStream",
      "timestamp": "2020-11-03T21:52:58.470000+00:00",
      "value": "dmFsdWUy"
    },
    {
      "key": "a2V5MQ==",
      "offset": 2,
      "partition": "0",
      "stream": "MyStream",
      "timestamp": "2020-11-03T22:00:48.305000+00:00",
      "value": "dmFsdWUx"
    },
    {
      "key": "a2V5Mg==",
      "offset": 3,
      "partition": "0",
      "stream": "MyStream",
      "timestamp": "2020-11-03T22:00:48.305000+00:00",
      "value": "dmFsdWUy"
    }
  ],
  "opc-next-cursor": "examplenextcursorvalue"
}

CLIコマンドのパラメータおよび値の完全なリストは、CLIコマンド・リファレンスを参照してください。

GetMessages操作を実行して、ストリームのメッセージを取得します。

Oracle Cloud Infrastructureドキュメント

メッセージの取得(読取り)