Obtention (lecture) de messages

À l'aide d'un curseur spécifié, obtenez (ou lisez) des messages à partir d'un flux du service de diffusion en continu. Un message est un message encodé en Base64 qui est publié dans un flux.

Pour plus d'informations sur les groupes de consommateurs et les consommateurs individuels pour l'obtention de messages, voir Utilisation de groupes de consommateurs et Utilisation de consommateurs individuels.

Cette tâche ne peut pas être effectuée à l'aide de la console.

Utilisez la commande oci stream message get et les paramètres requis pour obtenir les messages d'un flux :

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

Votre première demande d'obtention des messages doit utiliser la valeur retournée lorsque vous avez créé un curseur. Chaque demande suivante doit utiliser la valeur opc-next-cursor retournée dans la réponse précédente.

Par exemple :

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

Pour la liste complète des paramètres et des valeurs pour les commandes de l'interface de ligne de commande, voir .

Exécutez l'opération GetMessages pour obtenir les messages d'un flux.

Documentation sur Oracle Cloud Infrastructure

Obtention (lecture) de messages