Documentazione dell'infrastruttura Oracle Cloud

Come leggere i messaggi

Utilizzando un cursore specificato, ottenere (o leggere) i messaggi da un flusso nel servizio di streaming. Un messaggio è un messaggio con codifica Base64 pubblicato in un flusso.

Per informazioni sui gruppi di consumer e sui singoli consumer per il recupero dei messaggi, vedere Utilizzo dei gruppi di consumer e Utilizzo dei singoli consumer.
  • Questo task non può essere eseguito utilizzando la console.

  • Utilizzare il comando oci streaming stream message get e i parametri richiesti per ottenere i messaggi da un flusso:

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

    La prima richiesta di recupero dei messaggi deve utilizzare il valore restituito quando è stato creato un cursore. Ogni richiesta successiva deve utilizzare il valore opc-next-cursor restituito nella risposta precedente.

    Ad esempio:

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

    Per un elenco completo dei parametri e dei valori per i comandi della CLI, vedere il manuale CLI Command Reference.

  • Eseguire l'operazione GetMessages per ottenere i messaggi per un flusso.