Publicando uma Mensagem de Teste em um Fluxo

Emita (publice) uma mensagem de teste para um stream no serviço Streaming para garantir que o stream esteja funcionando.

Use a CLI, a API ou um SDK para preencher um stream. Para obter requisitos e recomendações para publicar mensagens, consulte Publicando Mensagens. Para publicar mensagens usando um SDK, consulte o Guia do Desenvolvedor para Streaming.

1. Na página da lista Streams, selecione o stream com o qual você deseja trabalhar. Se precisar de ajuda para encontrar a página da lista ou o stream, consulte Listando Streams.
2. Na página de detalhes, selecione Produzir Mensagem de Teste.
3. Na caixa Dados, digite a mensagem somente texto a ser publicada.
4. Selecione Produzir.

Use o comando oci streaming stream message put e os parâmetros necessários para publicar uma mensagem de teste em um stream:

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

Dica

Forneça uma entrada para --messages como JSON com formato válido. Consulte Especificando Entrada Complexa e Usando um Arquivo JSON para Entrada Complexa para obter informações sobre a formatação JSON.

Por exemplo, file.txt contém o JSON formatado corretamente. Seus valores são codificados em Base64:

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

O parâmetro --messages usa o arquivo como seu valor:

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

Execute a operação PutMessages para publicar uma mensagem de teste em um stream.

Documentação do Oracle Cloud Infrastructure

Publicando uma Mensagem de Teste em um Fluxo