Documentation sur Oracle Cloud Infrastructure

Publication d'un message de test dans un flux

Émettez (publiez) un message de test dans un flux du service de diffusion en continu pour vous assurer que le flux fonctionne.

Utilisez l'interface de ligne de commande, l'API ou une trousse SDK pour alimenter un flux. Pour connaître les exigences et les recommandations relatives à la publication des messages, voir Publication de messages. Pour publier des messages à l'aide d'une trousse SDK, voir Guide du développeur pour le service de diffusion en continu.

    1. Dans la page de liste Flux, sélectionnez le flux avec lequel vous voulez travailler. Si vous avez besoin d'aide pour trouver la page de liste ou le flux, voir Liste des flux.
    2. Dans la page de détails, sélectionnez Produire un message de test.
    3. Dans la zone Données, entrez le message texte seulement à publier.
    4. Sélectionnez Produire.

  • Utilisez la commande oci streaming stream message put et les paramètres requis pour publier un message de test dans un flux :

    oci streaming stream message put --stream-id <stream_id> --messages <JSON_messages> --endpoint <messages_endpoint>
    Conseil

    Indiquez une entrée pour --messages dans un format JSON valide. Voir Transmission d'entrée complexe et Utilisation d'un fichier JSON pour une entrée complexe pour plus d'informations sur le formatage JSON.

    Par exemple, file.txt contient le JSON correctement formaté. Ses valeurs sont encodées en Base64 :

    [
  {
    "key": "a2V5MQ==",
    "value": "dmFsdWUx"
  },
  {
    "key": "a2V5Mg==",
    "value": "dmFsdWUy"
  }
]

    Le paramètre --messages prend le fichier comme valeur :

    oci streaming stream message put --stream-id ocid1.stream.oc1.phx.exampleuniqueID --messages file://file.txt --endpoint https://cell-1.streaming.us-phoenix-1.oci.oraclecloud.com  
{
  "data": {
    "entries": [
      {
        "error": null,
        "error-message": null,
        "offset": 0,
        "partition": "0",
        "timestamp": "2020-11-03T21:35:03.837000+00:00"
      },
      {
        "error": null,
        "error-message": null,
        "offset": 1,
        "partition": "0",
        "timestamp": "2020-11-03T21:35:03.837000+00:00"
      }
    ],
    "failures": 0
  }
}

  • Exécutez l'opération PutMessages pour publier un message de test dans un flux.