Tablestore:Realtime Compute for Apache Flink

Informações básicas

O Realtime Compute for Apache Flink é uma plataforma completa de análise de big data em tempo real, desenvolvida sobre o Apache Flink. Ele oferece análises de dados com latência inferior a um segundo e simplifica o desenvolvimento por meio de SQL padrão. A plataforma inclui um conector nativo do Tablestore para leitura, escrita e computação de dados diretamente nesse service. Para mais detalhes, consulte Appendix 1: Tablestore sink connector.

O Tablestore Tunnel Service é um service integrado construído sobre a API de dados do Tablestore que gerencia dados completos e incrementais. Crie um túnel de dados para uma tabela e use o processamento de fluxo para consumir tanto os dados existentes quanto os novos.

Cenários

A integração entre Tablestore e Flink atende aos seguintes cenários:

• Análise e processamento de dados em tempo real

  Ao usar o Tablestore como source de dados para jobs do Flink, você coleta e processa grandes volumes de dados estruturados em tempo real. Isso viabiliza o monitoramento de negócios e a análise de tendências instantaneamente, ajudando sua empresa a responder rapidamente às mudanças de mercado.

• Processamento de dados da Internet das Coisas (IoT)

  O Tablestore oferece um modelo de séries temporais para armazenar e processar dados de dispositivos IoT. Em conjunto com o Flink, essa solução permite monitoramento em tempo real, manutenção preditiva e tomada de decisão inteligente para aplicações como análise de trajetória de veículos e monitoramento ambiental.

• Monitoramento de riscos no setor financeiro

  Instituições financeiras precisam monitorar o comportamento das transações em tempo real para identificar ameaças potenciais e tomar as medidas adequadas. O Flink acompanha fluxos de dados transacionais continuamente para detectar comportamentos anômalos, como transferências frequentes de alto valor e logons incomuns. Em seguida, grava pontuações de risco ou registros de anomalias no Tablestore para auditoria e análise posteriores.

Para obter mais informações sobre os cenários do Flink, consulte Scenarios.

Faturamento

• Flink

  O Realtime Compute for Apache Flink cobra pelos recursos de gerenciamento e de computação. Para mais informações, consulte Product Billing.

• Tablestore

  O acesso ao Tablestore por meio de um mecanismo de computação gera cobranças pelas leituras e escritas de dados. Também há taxas de armazenamento conforme o volume de dados guardados. Para mais detalhes, consulte Billing overview.

Referências

• O Flink utiliza túneis de dados do Tunnel Service como source de dados em streaming para computar e analisar informações do Tablestore. Para instruções, consulte Tutorials.