标签计算
是否是文本消息
合并成会话段
例外人员策略cache
脱敏规则cache
文本
ORC图片识别服务
根据业务处理情况丁日批量更新到ck中
标签定义
kafka
转发
oneIdRedis缓存
监听事件
xxx
调用API更新cache
ES
调用API更新脱敏加密规则cache
开始
CK
单句入库cache
data-moral
段落数据入库
oneId关联
否
source
规则匹配
是否是图片消息
关联人员
是
定时批量数据同步
判定是否存档&数据类型
明文替换为12个*
调用API更新脱敏规则cache
标签中心
asr-servercontent-extraction-serverocr-server
是否是会话消息
事件监听【业务数据更新操作】
session-flink-server
Kafka集群
消息体解密
语音通话识别
Mysql/ClickHouse/ES/对象存储
Redis
实时入库【单句/会话】
Mysql
窗口标签计算
关联商机
拉取标签
数据入库
CRM员工/外部联系人缓存信息
数据层
开始流程1
数据查询服务
查询会话关联的人员数据
时间管理数据查询
数据伦理
结束
调用SDK文本脱敏加密
脱敏加密规则cache
应用层查询
oneId维护【fedp】【每日定时刷新、重启刷新】
图片识别
songshan-dm-server
计算层
session-tag-server
根据逻辑切分会话
伦理规则刷新策略【启动刷新缓存、规则修改DE回调】
调用SDK文本脱敏
oneId缓存
判定文本是否存档
单句数据
内容提取
数据源接入【企微/灵听】
应用层
MOS话轮数据查询
入库
查询/搜索API
语音消息识别
CRM事件监听【客户联系人关联客户/商机及关联系群聊-协作成员】
伦理服务拆分【判断数据存到后部分类型的企微消息获取不到数据文本信息】
文本数据
数据缓存到mysql
文本替换为12个*语音/文件数据置空
数据伦理【加密/脱敏】
会话数据计算【分段/标签】
企微会话查询
汇报数据查询
企微数据源接入数据来源【DI】
企微分段计算段落、窗口标签计算
