鑫合汇事件规则匹配预警系统

一、项目功能介绍

该系统可通过埋点消息进行事件规则的匹配，实现预警通知、性能监控、数据统计等功能。

二、系统架构

2.1、技术框架

系统基于Storm分布式实时处理框架，以Kafka作为消息来源，Mongodb作为存储介质。由Rabbitmq广播通知给客户端。SpringBoot作为Web监控展示平台供用户查询监控记录，增删预警事件规则的配置。

监控展示平台测试地址：http://172.19.19.232:8080/ 账号/密码：manage/manage2018

2.2、系统时序图

2.3、系统类图

三、如何接入

3.1、消息埋点

3.1.1、日志格式约定

3.1.2、日志记录样例

• 格式：json字符串
• 客户经理发起二次展期行为日志

{"timestamp":"2018-07-25T00:26:15.000000+08:00", "channel":"xhh.point", "service":"xd", "action":"extended", "unique_id":"G20180502004321", "property":{"extended_times":"2", "expire_time":"2018-07-30 00:00:00"}}

3.2、消息推送

在客户端使用Filebeat推送埋点生成的日志到Kafka

3.3、定义事件匹配规则

• 格式：yaml
• 监控规则可配置属性字段类图：
  
• 示例：

key : INC-0002
title : 风审通过后，15天内未放款
action :
    - through_risk_trial
post_action : loan
trigger :
    -
        type : datetime
        compare : gt # 默认与日志中的timestamp进行比较
        target : expire_time # 指定target，则与埋点消息属性property的expire_time键值进行比较
        value : 15
        unit: day

key : YRZ-001
title : 匹配投资金额大于账户余额
action : finance
trigger :
    -
        type : compare
        compare : gt
        from : finance_amout
        target : account_amout

key : YRZ-002
title : 财务完成了还款充值，但超过5分钟未调用还款系统
action : repayment_recharge
post_action : call_repayment_action
trigger :
    -
        type : datetime
        compare : gt
        value : 5
        unit : minute

3.4、客户端监听预警消息并实现通知

预警系统并不包含消息系统，通过什么方式通知当事人（如短信，邮件，站内消息等）需客户端自己完成。预警系统会将匹配到的监控事件广播给Rabbitmq，由客户端自行消费处理。