整合

搭建企业数据中心，跨平台统一保险客户数据

标识

将散乱的数据重新梳理，以用户唯一标识展现

个性化

构建保险行业标签体系，支撑个性化营销落地

监测

围绕用户全生命周期建立监测，提升产品体验

挖掘

客户数据深度挖掘和利用，落地个性化运营

运营

提升保险企业精细化客户运营能力和体验用户

数据采集

采集部分使用OGG源端抽取变化数据，然后发送给OGG for BigData目标端，OGG db以JSON格式把数据写入分布式消息队列Kafka。

分布式计算

计算和关联采用分布式计算框架Spark，开发语言使用Java。通过读取Kafka的消息，根据不同的数据操作种类，实时删除、更新、插入新的数据。

分布式存储

分布式存储采用HBase和ElasticSearch。HBase存储合并后的宽表数据。ElasticSearch用来建立查询索引，提高数据查询效率。

数据查询服务

数据查询服务提供RESTful API、gRPC方式的数据查询服务，也可提供数据推送服务。数据查询服务采用基于SpringBoot的微服务框架。查询服务根据传入的查询条件，通过ElasticSearch系统快速找出符合查询条件的RowKey集合，然后通过RowKey从HBase获取数据给客户端。