【13章】Flink 从0到1实战实时风控系统
网盘地址:https://pan.baidu.com/s/1R4Hl3DYCMXAAKcEyKof91w
提取码:t52k
腾讯微云下载地址:https://share.weiyun.com/dy3vBkhl
密码:9uu7z5
分享一套课程——【13章】Flink 从0到1实战实时风控系统,附源码+笔记下载,课程包更新。
风控系统是系统的一种,除了具备系统的三个特征之外,还具有两个特征:一是计算机系统,包含软件、硬件、数据。二是服务于风控业务,在风控领域使用。
风控系统分为在线系统和离线系统。
在线系统:
即产生真实业务结果,如审批系统;
离线系统:
不产生真实业务结果,主要作用是展示和分析,如BI系统,建模平台。
大数据风控系统提供一站式风险预警解决方案,通过数据采集,规则检查,风险分析,实时监测出交易环节高频交易,可以交易,大额交易等行为,通过大数据、规则引擎、流式计算、机器学习等技术手段,能快速有效地识别异常行为,从而为银行、第三方支付、电商行业等领域的发展提供重要的安全保障。
不放过任何一个风险隐患,事前事中事后全程监督管理,拒绝作弊损失,保障支付安全。
Apache Flink的数据流编程模型在有限和无限数据集上提供单次事件(event-at-a-time)处理。在基础层面,Flink程序由流和转换组成。 [3]
Apache Flink的API:有界或无界数据流的数据流API、用于有界数据集的数据集API、表API。 [3]
数据流的运行流程
Flink程序在执行后被映射到流数据流,每个Flink数据流以一个或多个源(数据输入,例如消息队列或文件系统)开始,并以一个或多个接收器(数据输出,如消息队列、文件系统或数据库等)结束。Flink可以对流执行任意数量的变换,这些流可以被编排为有向无环数据流图,允许应用程序分支和合并数据流。
Flink的数据源和接收器
Flink提供现成的源和接收连接器,包括Apache Kafka、Amazon Kinesis、HDFS和Apache Cassandra等。
Flink程序可以作为集群内的分布式系统运行,也可以以独立模式或在YARN、Mesos、基于Docker的环境和其他资源管理框架下进行部署。