Configuración de salida de la aplicación - Guía para desarrolladores de aplicaciones de Amazon Kinesis Data Analytics para SQL
Creación de una salida mediante el AWS CLI

Para proyectos nuevos, le recomendamos que utilice el nuevo servicio gestionado para Apache Flink Studio en lugar de aplicaciones de Kinesis Data Analytics para SQL. El servicio gestionado para Apache Flink Studio combina la facilidad de uso con capacidades analíticas avanzadas, lo que le permite crear aplicaciones sofisticadas de procesamiento de flujos en cuestión de minutos.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Configuración de salida de la aplicación

En el código de la aplicación, escriba la salida de las instrucciones SQL en una o más secuencias en la aplicación. Si lo desea, puede añadir una configuración de salida a su aplicación para conservar todo lo escrito en una transmisión de la aplicación a un destino externo, como una transmisión de datos de Amazon Kinesis, una transmisión de entrega de Firehose o una función. AWS Lambda

Existe un límite en cuanto al número de destinos externos que puede utilizar para conservar datos en la salida de una aplicación. Para obtener más información, consulte Límites.

nota

Le recomendamos que utilice un destino externo para almacenar los datos de secuencia de errores en la aplicación para que pueda investigar los errores.

En cada una de estas configuraciones de salida, debe proporcionar lo siguiente:

  • Nombre de la secuencia en la aplicación: la secuencia que desea conservar en un destino externo.

    Kinesis Data Analytics busca la secuencia en la aplicación que ha especificado en la configuración de salida. (El nombre de la secuencia distingue entre mayúsculas y minúsculas y deben coincidir exactamente). Asegúrese de que el código de la aplicación crea esta secuencia en la aplicación.

  • Destino externo: puede conservar los datos en una transmisión de datos de Kinesis, una transmisión de entrega de Firehose o una función Lambda. Proporciona el nombre de recurso de Amazon (ARN) de la secuencia o función. Además proporciona un rol de IAM que Kinesis Data Analytics puede asumir para escribir la secuencia o función en su nombre. Debe describir el formato de registro (JSON o CSV) que Kinesis Data Analytics debe utilizar a la hora de escribir en el destino externo.

Si Kinesis Data Analytics no puede escribir en el destino de streaming o de Lambda, el servicio sigue intentándolo de forma indefinida. Con ello se crea resistencia y la aplicación se queda retrasada. Si el problema no se resuelve, la aplicación finalmente detiene el procesamiento de datos nuevos. Puede monitorizar las métricas de Kinesis Data Analytics y establecer alarmas para los errores. Para obtener más información sobre las métricas y las alarmas, consulte Uso de Amazon CloudWatch Metrics y Creación de CloudWatch alarmas de Amazon.

Puede configurar la salida de la aplicación usando la AWS Management Console. La consola realiza la llamada a la API para guardar la configuración.

Creación de una salida mediante el AWS CLI

En esta sección, se describe cómo crear la sección Outputs del cuerpo de la solicitud para una operación CreateApplication o AddApplicationOutput.

Creación de una salida de secuencias de Kinesis

El siguiente fragmento de JSON muestra la sección Outputs del cuerpo de la solicitud CreateApplication que se utiliza para crear un destino hacia un flujo de datos de Amazon Kinesis.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisStreamsOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
 
]

Creación de una salida de flujo de entrega de Firehose

El siguiente fragmento de JSON muestra la Outputs sección del cuerpo de la CreateApplication solicitud para crear un destino de transmisión de entrega de Amazon Data Firehose.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "KinesisFirehoseOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]

Creación de una salida de la función de Lambda

El siguiente fragmento de JSON muestra la Outputs sección del cuerpo de la CreateApplication solicitud para crear un destino de AWS Lambda función.

"Outputs": [
   {
       "DestinationSchema": {
           "RecordFormatType": "string"
       },
       "LambdaOutput": {
           "ResourceARN": "string",
           "RoleARN": "string"
       },
       "Name": "string"
   }
]