Documentación de Oracle Cloud Infrastructure

Obtención (lectura) de mensajes

Mediante un cursor especificado, obtenga (o lea) mensajes de un flujo en el servicio Streaming. Un mensaje es un mensaje codificado en Base64 que se publica en un flujo.

Para obtener información sobre grupos de consumidores y consumidores individuales para obtener mensajes, consulte Uso de grupos de consumidores y Uso de consumidores individuales.
  • Esta tarea no se puede realizar con la consola.

  • Utilice el comando oci stream message get y los parámetros necesarios para obtener mensajes de un flujo:

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

    Su primera solicitud para obtener mensajes debe utilizar el valor devuelto cuando creó un cursor. Cada solicitud posterior debe utilizar el valor opc-next-cursor devuelto en la respuesta anterior.

    Por ejemplo:

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

    Para obtener una lista completa de parámetros y valores para los comandos de la CLI, consulte la referencia de comandos de la CLI.

  • Ejecute la operación GetMessages para obtener mensajes para un flujo.