OceanBase 实时分析Demo 解析：Flink + OceanBase_ob 4.3.0

先看看实时分析的Demo效果演示

Demo说明：

• 这个汽车下单Demo支持在PC端进行下单操作，同时也支持多人通过手机扫码在线下单
• 订单数据被实时写入OceanBase TP数据库，并通过Flink CDC 实时同步到OceanBase AP数据库。Demo中的分析看板从AP库中查询最新的数据进行展示。
• 无论是执行简单的count(*)计数查询，还是进行包含where、group by、order by等多条件的查询，系统都能在近亿级别的数据规模下，保证查询耗时基本在10ms到100ms之间，这充分体现了OceanBase AP数据库的查询性能。（此查询耗时已包含了后端到数据库之间的网络延时，因此数据库内部实际的SQL执行耗时将会更低）
• 只建了主键索引。

Demo实现

准备数据库

• TP 数据库: OB 4.3.0 行存 + 开启 Binlog 服务
• AP 数据库: OB 4.3.0 列存

使用 OBCloud 阿里云版本

• 为了降低搭建成本，方便后续和 Flink 以及应用进行集成，直接使用 OBCloud 阿里云版本，数据库配置如下:
  • OB 版本 4.3.0.1，目前该版本在 OBCloud 需要开通白名单才能购买，具体可以联系官方技术服务同学进行开通。
  • 我这里购买一个按需付费的集群实例，3 节点，节点规格为 14C70G，价格 ¥32/小时。如果只用于测试，可以申请 https://www.wpsshop.cn/w/神奇cpp/article/detail/846071