基于Flink Job的实时风控引擎设计与实现

本文介绍了一种基于 Flink Job 的实时风控引擎的设计与实现方案。规则引擎模块的设计采用 Flink Job 形式来实现管理与运行。每条 Flink Job 包含不同的规则，构成逻辑使用业务数据库 MySQL 来实现管理与运行。即每一条规则定义都需要在 Flink 中事先定义，再使用定义来产生一个可以实现的规则文件，以便将其放入 Flink 内存中实现。通过对整个系统模型进行分析，我们构建了一套完整的风控运行框架，包括数据采集与存储、业务规则建模及验证、算法实现以及结果输出、系统部署与运维等。实时风控计算引擎可以计算并识别异常交易行为，构建统一风控模型，对来自多个交易系统的交易行为进行集中甄别。同时，紧跟监管要求的风控规则算法模型，实现一套能同时解决交易高频低时延要求和海量数据高吞吐高并发高可靠性要求的风控引擎。