Documentação do Oracle Cloud Infrastructure

Obtendo (Lendo) Mensagens

Usando um cursor especificado, obtenha (ou leia) mensagens de um stream no serviço Streaming. Uma mensagem é uma mensagem codificada em Base64 que é publicada em um stream.

Para obter informações sobre grupos de consumidores e consumidores individuais para obter mensagens, consulte Usando Grupos de Consumidores e Usando Consumidores Individuais.
  • Essa tarefa não pode ser executada usando a Console.

  • Use o comando oci streaming stream message get e os parâmetros necessários para obter mensagens de um stream:

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

    Sua primeira solicitação para obter mensagens deve usar o valor retornado quando você criou um cursor. Cada solicitação subsequente deve usar o valor opc-next-cursor retornado na resposta anterior.

    Por exemplo:

    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 obter uma lista completa de parâmetros e valores para comandos da CLI, consulte a Referência de Comandos da CLI..

  • Execute a operação GetMessages para obter mensagens de um stream.