Publicación de un mensaje de prueba en un flujo

Emita (publicue) un mensaje de prueba en un flujo del servicio Streaming para garantizar que el flujo funciona.

Utilice la CLI, la API o un SDK para rellenar un flujo. Para conocer los requisitos y recomendaciones para publicar mensajes, consulte Publicación de mensajes. Para publicar mensajes mediante un SDK, consulte la Guía del desarrollador para Streaming.

    1. En la página de lista Flujos, seleccione el flujo con el que desea trabajar. Si necesita ayuda para buscar la página de lista o el flujo, consulte Lista de flujos.
    2. En la página de detalles, seleccione Producir mensaje de prueba.
    3. En el cuadro Datos, introduzca el mensaje de solo texto que desea publicar.
    4. Seleccione Producir.
  • Utilice el comando oci streaming stream message put y los parámetros necesarios para publicar un mensaje de prueba en un flujo:

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

    Proporcione una entrada para --messages como JSON con formato válido. Consulte Transferencia de entrada compleja y Uso de un archivo JSON para entrada compleja para obtener más información sobre el formato JSON.

    Por ejemplo, file.txt contiene el formato correcto de JSON. Sus valores están codificados en Base64:

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

    El parámetro --messages toma el archivo como su 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
      }
    }
  • Ejecute la operación PutMessages para publicar un mensaje de prueba en un flujo.