Documentation Oracle Cloud Infrastructure

Publication d'un message de test vers un flux

Emettez (publiez) un message de test dans un flux du service Streaming pour vous assurer que le flux fonctionne.

Utiliser l'interface de ligne de commande, l'API ou un kit SDK pour remplir un flux. Pour connaître les exigences et les recommandations relatives à la publication de messages, reportez-vous à Publication de messages. Pour publier des messages à l'aide d'un kit SDK, reportez-vous au guide du développeur pour Streaming.

    1. Sur la page de liste Flux de données, sélectionnez le flux de données à utiliser. Si vous avez besoin d'aide pour rechercher la page de liste ou le flux de données, reportez-vous à Liste des flux de données.
    2. Sur la page de détails, sélectionnez Produire un message de test.
    3. Dans la zone Données, entrez le message texte uniquement à 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. Pour plus d'informations sur le formatage JSON, reportez-vous à Transmission d'une entrée complexe et à Utilisation d'un fichier JSON pour une entrée complexe.

    Par exemple, file.txt contient le document JSON de format correct. 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 de données.