Consultas en ventana - Guía para desarrolladores de Amazon Kinesis Data Analytics

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.

Consultas en ventana

Las consultas SQL en el código de la aplicación pueden ejecutarse de forma continua a través de secuencias en la aplicación. En una secuencia en la aplicación representa un datos ilimitados que fluyen de forma continua a través de su aplicación. Por lo tanto, para obtener resultados de esta salida que se actualiza de forma constante, a menudo se unen consultas utilizando una ventana definida en términos de tiempo o de filas. Estas también se denominan SQL en ventana.

Para una consulta en ventana basada en el tiempo, debe especificar el tamaño de la ventana expresado en unidades de tiempo (por ejemplo, una ventana de un minuto). Esto requiere una columna de marca temporal en la secuencia en la aplicación que aumente de forma monótona. (La marca temporal para una nueva fila es mayor o igual que la de la fila anterior.) Amazon Kinesis Data Analytics proporciona una columna de marca temporal llamadaROWTIMEpara cada secuencia en la aplicación. Puede utilizar esta columna al especificar las consultas basadas en el tiempo. Para su aplicación, puede elegir otra opción de marca temporal. Para obtener más información, consulte Marcas temporales y la comuna ROWTIME .

Para una consulta en ventana basada en filas, debe especificar el tamaño de la ventana expresado como un número de filas.

Puede especificar una consulta para procesar registros en una ventana de saltos, una ventana deslizante o una ventana escalonada, según las necesidades de la aplicación. Kinesis Data Analytics admite los siguientes tipos de ventana:

  • Ventanas escalonadas: una consulta que agrupa los datos usando ventanas basadas en tiempo con clave que se abren cuando llegan los datos. Las claves permiten que se superpongan varias ventanas. Esta es la forma recomendada de agrupar los datos utilizando ventanas de tiempo, ya que las ventanas escalonadas reducen la cantidad de datos recibidos con retraso o desordenados en comparación con las ventanas de saltos.

  • Ventanas de saltos de tamaño constante: una consulta que agrupa los datos usando ventanas de tiempo que se abren y cierran a intervalos regulares.

  • Ventanas deslizantes: una consulta que agrega datos continuamente, utilizando un intervalo de tiempo fijo o de número de filas.