整合
搭建企業(yè)數(shù)據中心,跨平台統一(yī)保險客戶≈☆數(shù)據
标識
将散亂的(de)數(shù)據重新梳理(lǐ),以用(yòng)戶唯一(yī)标識展→>現(xiàn)
個(gè)性化(huà)
構建保險行(xíng)業(yè)标簽體(tǐ)系,支撐個(gè)性化(huà)營α☆ π銷落地(dì)
監測
圍繞用(yòng)戶全生(shēng)命周期建立監測,提升産品體(tǐ)驗×↑"β
挖掘
客戶數(shù)據深度挖掘和(hé)利用(yòng),落地(dì)個(gè)性化(huà)♠'÷運營
運營
提升保險企業(yè)精細化(huà)客戶運營能(néng)力和(hé)體Ωφ$(tǐ)驗用(yòng)戶
數(shù)據采集
采集部分(fēn)使用(yòng)OGG源端抽取變化(huà)數(shù£®σ∑)據,然後發送給OGG for BigDa ←¶↔ta目标端,OGG db以JSON格式把數(shù)據寫入分(fēn)布Ω←β式消息隊列Kafka。
分(fēn)布式計(jì)算(suàn)
計(jì)算(suàn)和(hé)關聯采用(yòng)分(fσ ∏♦ēn)布式計(jì)算(suàn)框架Spar↓λk,開(kāi)發語言使用(yòng)Jav •<a。通(tōng)過讀(dú)取Kafka的(de)消息,根據不(bù)同的(de)數(↕↑≤₩shù)據操作(zuò)種類,實時(shí)删除、更新、插入π₩新的(de)數(shù)據。
分(fēn)布式存儲
分(fēn)布式存儲采用(yòng)HB"≠ase和(hé)ElasticSearch。HBase存儲φ∞合并後的(de)寬表數(shù)據。ElasticSearch用(yòng)來(lái)建立$÷查詢索引,提高(gāo)數(shù)據查詢效率。
數(shù)據查詢服務
數(shù)據查詢服務提供RESTful API、gRPC方式的(↑±₹de)數(shù)據查詢服務,也(yě)可(kě)提供數(shù)據推送服務。數(s∑☆hù)據查詢服務采用(yòng)基于Spri®♦ngBoot的(de)微(wēi)服務框架。查詢服務根φ據傳入的(de)查詢條件(jiàn),通(tōng)過ElasticSearch系φ↓統快(kuài)速找出符合查詢條件(jiàn)的(de)RowKey集合,然後通("☆tōng)過RowKey從(cóng)HBase獲取數(shù)據給客戶端。
個(gè)人(rén)保單大(dà)寬表數(shùφ×)據實時(shí)生(shēng)成系統
系統實現(xiàn)了(le)一(yī)個< (gè)流式大(dà)寬表數(shù)據系統,系統實時(shí)采集核心系統數(shù★$₽±)據的(de)變化(huà),采用(yòng)分₹ ←(fēn)布式流式處理(lǐ)方式實時(shí)關聯多(duō)表數(s♠←hù)據,實時(shí)處理(lǐ)數(shù)據增删改變化(h↕γ≠∑uà)事(shì)件(jiàn),并存入MPP數(shù)據庫供其它程∑εβ序查詢和(hé)分(fēn)析使用(yòng)。