实时计算Flink

背景信息

实时计算Flink版是一套基于Apache Flink构建的一站式实时大数据分析平台，提供端到端亚秒级实时数据分析能力，并通过标准SQL降低了业务开发的门槛。平台内置了表格存储Tablestore连接器，用于Tablestore的数据读写与计算。更多信息，请参见附录1：Tablestore连接器。

表格存储通道服务（Tunnel Service）是基于表格存储数据接口上的全增量一体化服务。通过为数据表建立数据通道，您可以通过流式计算的方式对表中存量和新增数据进行消费处理。

应用场景

表格存储与Flink结合的方案可以实现如下场景需求：

• 实时数据分析与处理

  利用表格存储作为Flink作业的数据源，可以实现对海量结构化数据的实时采集与处理，从而帮助用户实时监控业务数据、实时分析数据趋势，以满足企业对市场动态快速响应的要求。

• 物联网数据处理

  表格存储的时序模型是专门针对时间序列数据的特点进行设计，非常适合存储和处理物联网设备生成的时序数据。结合Flink的实时计算能力，可以实现实时监控分析、预测性维护和智能决策，例如车辆轨迹分析、环境监测等应用。

• 金融行业风险监控

  金融机构需对交易行为进行实时监控，以识别潜在风险并采取相应措施。通过Flink对交易数据流进行实时监控，检测异常行为（例如频繁的大额转账、异地登录等），并将风险评分或异常记录写入表格存储，以便后续进行审计和分析。

更多Flink的应用场景，请参见应用场景。

计费说明

• Flink

  实时计算Flink的计费项包括管控资源和计算资源。详细计费信息，请参见产品计费。

• 表格存储

  在使用计算引擎访问表格存储时，表格存储将会收取读写数据的相关费用。数据写入后，表格存储会根据数据存储量收取相应存储费用。详细计费信息，请参见计费概述。

相关文档

• 实时计算Flink能够将通道服务的数据通道作为流式数据的输入，从而实现对表格存储数据的计算与分析。具体操作，请参见使用教程。

• 表格存储结合实时计算Flink，能够为多种业务场景提供强大的数据处理能力。更多信息，请参见表格存储结合实时计算Flink进行大数据分析和表格存储结合实时计算Flink实现交易数据的实时统计。