Pubblicazione di un messaggio di test in un flusso

Emettere (pubblicare) un messaggio di test su un flusso nel servizio di streaming per assicurarsi che il flusso funzioni.

Utilizzare l'interfaccia CLI, l'API o un SDK per popolare un flusso. Per i requisiti e i suggerimenti per la pubblicazione dei messaggi, vedere Pubblicazione dei messaggi. Per pubblicare messaggi utilizzando un SDK, vedere la Guida per gli sviluppatori allo streaming.

1. Nella pagina di elenco Streams, selezionare il flusso con cui si desidera lavorare. Per assistenza nella ricerca della pagina di elenco o del flusso, vedere Elenco di flussi.
2. Nella pagina dei dettagli selezionare Produci messaggio di test.
3. Nella casella Dati, immettere il messaggio di solo testo da pubblicare.
4. Selezionare Produci.

Utilizzare il comando oci streaming stream message put e i parametri richiesti per pubblicare un messaggio di test in un flusso.

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

Suggerimento

Fornire l'input per --messages come JSON formattato valido. Per informazioni sulla formattazione JSON, vedere Passaggio dell'input complesso e Utilizzo di un file JSON per l'input complesso.

Ad esempio, file.txt contiene il formato JSON corretto. I relativi valori sono Base64-encoded:

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

Il parametro --messages accetta il file come valore:

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

Eseguire l'operazione PutMessages per pubblicare un messaggio di test in un flusso.

Documentazione di Oracle Cloud Infrastructure

Pubblicazione di un messaggio di test in un flusso