开普勒平台流程图
2020-01-06 11:16:14 0 举报
开普勒架构
作者其他创作
大纲/内容
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分钟,数据同步定时任务
0 条评论
回复 删除
下一页