Documentation Oracle Cloud Infrastructure

Obtention (lecture) de messages

A l'aide d'un curseur spécifique, obtenez (ou lisez) des messages à partir d'un flux dans le service Streaming. Un message est un message encodé en Base64 publié dans un flux de données.

Pour plus d'informations sur les groupes de destinataires et les destinataires individuels pour obtenir des messages, reportez-vous aux rubriques Utilisation des groupes de destinataires et Utilisation des destinataires individuels.
  • Cette tâche ne peut pas être effectuée à l'aide de la console.

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

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

    La première demande d'obtention de messages doit utiliser la valeur renvoyée lors de la création d'un curseur. Chaque demande suivante doit utiliser la valeur opc-next-cursor renvoyée dans la réponse précédente.

    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 obtenir la liste complète des paramètres et valeurs des commandes de la CLI, reportez-vous à la référence des commandes de la CLI.

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