CN112766975B 一种风险侦测方法、装置、电子设备和可读存储介质 （中信银行股份有限公司）

所述方法包括将获取的目标用户的目标交易数据存储于Kafka消息系统；基于ApacheStorm的程序读取Kafka消息系统中的目标交易数据；基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易数据进行分析处理并输出分2基于ApacheStorm的程序读取Kafka消息系统中的目基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易数据进行分析处所述时间窗口可用于写入目标交易数据和风险侦测规则。提取所述目标交易数据至少一个特征信息；其中所述目标交易数据根据所述提取的至少一个特征信息将所述目标交易数据划分为3.根据权利要求2所述的风险侦测方法，其特征在于，在基于将所述N个分片的目标交易数据存储于Cassandr4.根据权利要求3所述的风险侦测方法，其特征在于，所述基于Apache解析N个分片的目标交易数据中特征信息并处理为能被Esper处理的格Esper读取Cassandra数据库中的目标交易数据，并按照所所述Kafka消息系统根据所述风险告警信息向系统发送6.根据权利要求5所述的风险侦测方法，其特征在于，所述基于Apac所述读取模块，还用于基于ApacheStorm的程序读取Kafka消息系统中的目标交易数所述处理模块，还用于基于ApacheStorm和Esper复杂事件处理组件的程序对所述目3算机程序被处理器执行时实现权利要求1-64交易量激增时(如双十一零点后巨量客户集中进行消费交易)，需查询数据库的SQL数量被[0007]基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易数据进行分[0013]可选地，在基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易[0015]可选地，所述基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交5[0030]所述读取模块，还用于基于ApacheStorm的程序读取Kafka消息系统中的目标交[0031]所述处理模块，还用于基于ApacheStorm和Esper复杂事件处理组件的程序对所ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易数据进行分析处理并输出[0040](1)系统依赖分布式的Kafka消息队列、分布式计算框架Storm、分布式数据库6[0052]Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动[0053]ApacheStorm是一个免费开源的分布式实时计算系统。简化了流数据的可靠处非关系的数据库，类似于Google的BigTable。Cassandra的主要特点就是它不是一个数据风险侦测方式存在以下技术问题：(1)这种方式在交易数据激增时会存在数据库性能急剧7快速调整以响应变化.但是分布式流计算组件在计算交易相关的风险特征时，每新增一个[0058]下面将结合附图以具体地实施例对本申请的技术方案以及本申请的技术方案如处理KafkaTopic中的一个或多个对[0065]S103、基于ApacheStorm和Esper复杂事件处理组件的程序对所述目标交易数据[0066]本申请实施例中所述的Esper是复杂事件处理组件，内嵌在Java进程之中。在8至Kafka消息系统的消息队列，即将触发规则的报警交易发送至Kafka消息系统另一Topic中以触发系统后续的处置，Kafka消息系统根据所述风险告警信息向系统发送风险处置消[0069]在本申请可选实施例中，在基于ApacheStorm和Esper复杂事件处理组件的程序为将保存卡片授权交易数据的表(命名为tran_window)，应以卡号为分区的Partitioning9[0092]所述202存储模块，用于将获取的目标用户的目标交易数据存储于Kafka消息系[0101]在可选实施例中，所述存储模块用于将所述N个分片的目标交易数据存储于[0102]所述数据处理模块，其中所述数据处理模块用于解析N个分片的目标交易数据中[0108]在本申请可选实施例中，所述基于ApacheStorm和Esper复杂事件处理组件的程[0111]可以理解的是，本实施例中的风险侦测装置的上述各模块具有实现图1中所示的[0117]处理器2001可以是CPU(CentralProcessingUnit，中央DSP(DigitalSignalProcessor，数据信号处理器)，ASIC(ApplicationSpecific实现或执行结合本申请公开内容所描述的各种示例性的逻辑方框，模块和电路。处理器[0118]总线2002可包括一通路，在上述组件之间传送信息。总线2002可以是PCI(PeripheralComponentInterconnect，外设部件互连标准)总线或EISA(Extended[0119]存储器2003可以是ROM(ReadOnlyMemory，只读存储器)或可存储静态信息和指信息和指令的其他类型的动态存储设备，也可以是EEPROM(ElectricallyErasableProgrammableReadOnlyMemory，电可擦可编程只读存储器)、CD-ROM(CompactDiscApach