za-pre-stromeye写入ES
Handler.Out格转ConvertAop
众安叫blcs
合作方
console-TEST环境 定时任务检测
业务系统处理结果
签名验签
错误日志告警策略
应用启动，注册到high_availability
请求业务系统
错误日志分析
za-kepler-flink分析
日志收集filebeat
kepler全家桶
Handler.In格转ConvertAop
扫描表 high_availability
对应
开放平台
错误日志存储
是否开启审批流
batch
handler2
redis监听，逐台机器对比已配置的hostname
异常情况： 1、设置超时未同步处理； 2、非全量同步处理；性能：仅在点击上传之后，才为每一个同步动作生成定时检测任务。
Skywalking自定义Trace
Handler对应的ApplicationHandlerConfiguratorHandlerManager
读取binlog，按照shared column 投递kafka
open_gw后管平台配置(HSF/HTTP)
开普勒数据库
KeplerStandardTailHandlerInterceptor
router编排
合作方RAS公钥
公共oss上
定时任务自己心跳检查，更新注册时间
2、RSA加密业务字段
两个条件同时满足：1.测试环境2.配置了ons消息转发，
router.Out 格转StandardTailHandler
众安SDK验签解密，得到结果
开普勒console配置同步流程
查询：zk_kepler_data
kepler-config二方包
kepler-console
错误日志统计
ONS消息
......
router.In 格转StandardHeadHandler
任务一： 根据applicationName+ip更新high_av表；任务二： 同步配置(1) 同步配置是否已经开启，未开启结束；（2） 开启同步： 从 zk_kepler_data 查询所有数据，
batch里面的Handler
KeplerStandardHeadHandlerInterceptor
UAT点击同步，生成相应的 echo文件
application
六翼日志监控平台
1、拼接参数
导入操作，生成导入信息，回写oss
handler1
batch集群
收集（1）error级别日志（2）业务监控日志，monitorLog
开启定时任务
postLoan服务PROJECT_ID=8358kepler.application.url = 8358
SDK 众安RSA公钥
Test-环境定时任务检测到文件，更新同步状态，更新版本号
console-TEST环境
3、签名
4、发送Http请求
monitor日志直接入ES数据库
kafka错误日志
zk_kepler_version 新增一条数据
hostname匹配，消费消息
业务系统产生日志
console-PRE环境
Application对应的URLApplicationUrlConfigurator选取 8358 key对应的地址
product
合作方RAS私钥
查询数据库，注册时间+15min<当前时间 更新下线注册时间+5min<当前时间 更新异常
redis消息转发
KeplerAopInterceptor
3分钟心跳检查定时任务10分钟，数据同步定时任务
