Tablestore:Realtime Compute for Apache Flink

Contexto

Realtime Compute for Apache Flink es una plataforma integral de análisis de big data en tiempo real basada en Apache Flink. Ofrece análisis de datos en menos de un segundo y simplifica el desarrollo mediante SQL estándar. Incluye un conector nativo de Tablestore para leer, escribir y calcular datos en Tablestore. Para obtener más información, consulte Appendix 1: Tablestore sink connector.

Tablestore Tunnel Service es un servicio integrado basado en la API de datos de Tablestore que gestiona datos completos e incrementales. Permite crear un túnel de datos para una tabla y usar procesamiento de streaming para consumir tanto los datos existentes como los nuevos.

Escenarios

La combinación de Tablestore y Flink admite los siguientes escenarios:

• Análisis y procesamiento de datos en tiempo real

  Si utiliza Tablestore como origen de datos para los trabajos de Flink, podrá recopilar y procesar grandes volúmenes de datos estructurados en tiempo real. Esto permite monitorear el negocio y analizar tendencias al instante, lo que ayuda a su empresa a responder rápidamente a los cambios del mercado.

• Procesamiento de datos del Internet de las cosas (IoT)

  Tablestore proporciona un modelo de series temporales para almacenar y procesar datos de dispositivos IoT. Al combinarlo con Flink, se habilita el monitoreo en tiempo real, el mantenimiento predictivo y la toma de decisiones inteligente en aplicaciones como el análisis de trayectorias vehiculares y el monitoreo ambiental.

• Monitoreo de riesgos en el sector financiero

  Las instituciones financieras necesitan monitorear el comportamiento de las transacciones en tiempo real para identificar amenazas potenciales y tomar las medidas adecuadas. Flink monitorea flujos de datos transaccionales en tiempo real para detectar comportamientos anómalos, como transferencias frecuentes de montos elevados o inicios de sesión inusuales. Después, escribe las puntuaciones de riesgo o los registros anómalos en Tablestore para auditarlos y analizarlos posteriormente.

Para obtener más información sobre los escenarios de Flink, consulte Scenarios.

Facturación

• Flink

  Realtime Compute for Apache Flink cobra por los recursos de gestión y los recursos de cómputo. Para obtener más información, consulte Product Billing.

• Tablestore

  Acceder a Tablestore mediante un motor de cómputo genera cargos por lectura y escritura de datos. También se aplican tarifas de almacenamiento según el volumen de datos guardados. Para obtener más información, consulte Billing overview.

Referencias

• Flink puede usar los túneles de datos de Tunnel Service como origen de datos de streaming para calcular y analizar datos de Tablestore. Consulte las instrucciones en Tutorials.