-
公开(公告)号:CN112527779A
公开(公告)日:2021-03-19
申请号:CN202011536321.5
申请日:2020-12-22
Applicant: 北京明朝万达科技股份有限公司
Abstract: 本发明公开了一种事件处理方法、装置及系统。其中,该方法包括:监听目标事件,其中,目标事件包括如下至少之一:注册、下线、续约;获取监听到的目标事件的事件信息;根据目标事件的事件信息,确定目标事件是否出现异常。本发明解决了现有技术中各服务的运行状态无法自动检测、上报的技术问题。
-
公开(公告)号:CN112580092B
公开(公告)日:2023-03-24
申请号:CN202011419188.5
申请日:2020-12-07
Applicant: 北京明朝万达科技股份有限公司
Abstract: 本申请公开了一种敏感文件识别方法及装置。所述方法包括:根据预先配置的文件扫描路径,扫描得到目标文件;在所述目标文件的文件大小大于设定阈值的情况下,对所述目标文件进行分块处理,得到所述目标文件对应的多个文件块;调用所述多个文件块对应的线程,将所述多个文件块发送至消息队列;基于敏感信息分析程序读取所述消息队列中的所述目标文件对应的多个文件块;基于所述敏感信息分析程序对所述多个文件块进行敏感信息分析,得到所述目标文件对应的敏感等级。本申请实施例降低敏感数据泄露的风险,加强对重要信息的保护。
-
公开(公告)号:CN110569406B
公开(公告)日:2022-04-19
申请号:CN201910677173.X
申请日:2019-07-25
Applicant: 北京明朝万达科技股份有限公司
IPC: G06F16/9035 , G06F16/903
Abstract: 本发明提供一种互联网信息的热点数据分析方法、装置、系统及介质,所述方法包括:获取外部数据;创建Kafka生产者对象,建立热点数据配置模板;判断所述外部数据是否属于热点数据,若是,创建Kafka消费者对象,建立热度等级阈值配置模板,读取所述热点数据;根据所述热度等级阈值配置模板,对读取的所述热点数据进行匹配归类,确定所述热点数据对应的热度等级;对所述热点数据进行相应的处理。根据本发明的方案,实现了对热点数据进行动态分析处理,降低了开发成本,减少了后期再次维护的工作量,降低了代码的冗余度,提高了处理性能与容错率,解耦了热点数据的过滤、分析、审核的业务处理逻辑,降低了人力与时间的工作成本。
-
公开(公告)号:CN112580092A
公开(公告)日:2021-03-30
申请号:CN202011419188.5
申请日:2020-12-07
Applicant: 北京明朝万达科技股份有限公司
Abstract: 本申请公开了一种敏感文件识别方法及装置。所述方法包括:根据预先配置的文件扫描路径,扫描得到目标文件;在所述目标文件的文件大小大于设定阈值的情况下,对所述目标文件进行分块处理,得到所述目标文件对应的多个文件块;调用所述多个文件块对应的线程,将所述多个文件块发送至消息队列;基于敏感信息分析程序读取所述消息队列中的所述目标文件对应的多个文件块;基于所述敏感信息分析程序对所述多个文件块进行敏感信息分析,得到所述目标文件对应的敏感等级。本申请实施例降低敏感数据泄露的风险,加强对重要信息的保护。
-
公开(公告)号:CN110493342B
公开(公告)日:2021-05-14
申请号:CN201910775315.6
申请日:2019-08-21
Applicant: 北京明朝万达科技股份有限公司
Abstract: 本申请实施例提供了一种文件传输方法、装置、电子设备及可读存储介质,所述方法应用于文件传输系统,所述文件传输系统包括发送端和接收端,所述方法包括:在所述发送端获取待传输文件,确定传输所述待传输文件所需的多个第一线程;所述发送端根据所述多个第一线程,将所述待传输文件分割成多个文件块;所述发送端将所述多个文件块异步传输至kafka中;所述接收端采用预置的线程池中的多个第二线程,异步读取对应的文件块;其中,所述多个第二线程与所述多个第一线程的数量相同;所述接收端根据读取的每个文件块中的文件位置指针,将所述每个文件块写入对应的文件位置,完成文件的传输;以提高文件传输的速度和稳定性。
-
公开(公告)号:CN110750426A
公开(公告)日:2020-02-04
申请号:CN201911048254.X
申请日:2019-10-30
Applicant: 北京明朝万达科技股份有限公司
IPC: G06F11/30
Abstract: 本申请实施例提供了一种服务状态监测方法、装置、电子设备及可读存储介质,所述方法包括:所述Filebeat根据监控的服务数量,配置对应数量的日志监听输入源;所述Filebeat通过对每个日志监听输入源分别配置正则表达式,将每个日志监听输入源监控的服务所产生的运行日志进行过滤,以得到错误日志和告警日志;所述Filebeat根据所述异常类型标识,将所述错误日志和所述告警日志发送至对应的Kafka队列;所述Kafka根据不同的Kafka队列,将所述错误日志和所述告警日志分发至相应的处理程序中,以执行相应的操作;以帮助运维人员自动检测各个服务的状态并及时做出相应操作,避免了问题的遗留、堆积。节约了人力成本,提高了系统的运维效率。
-
公开(公告)号:CN110569406A
公开(公告)日:2019-12-13
申请号:CN201910677173.X
申请日:2019-07-25
Applicant: 北京明朝万达科技股份有限公司
IPC: G06F16/9035 , G06F16/903
Abstract: 本发明提供一种互联网信息的热点数据分析方法、装置、系统及介质,所述方法包括:获取外部数据;创建Kafka生产者对象,建立热点数据配置模板;判断所述外部数据是否属于热点数据,若是,创建Kafka消费者对象,建立热度等级阈值配置模板,读取所述热点数据;根据所述热度等级阈值配置模板,对读取的所述热点数据进行匹配归类,确定所述热点数据对应的热度等级;对所述热点数据进行相应的处理。根据本发明的方案,实现了对热点数据进行动态分析处理,降低了开发成本,减少了后期再次维护的工作量,降低了代码的冗余度,提高了处理性能与容错率,解耦了热点数据的过滤、分析、审核的业务处理逻辑,降低了人力与时间的工作成本。
-
公开(公告)号:CN109739913A
公开(公告)日:2019-05-10
申请号:CN201811581023.0
申请日:2018-12-24
Applicant: 北京明朝万达科技股份有限公司
IPC: G06F16/25 , G06F16/215
Abstract: 本发明提供了一种基于可配置化的热点数据缓存处理方法,包括:接收外部系统推送的数据;将所述推送的数据发送给提供MySQL服务的MySQL服务装置和提供热点数据缓存服务的热点数据缓存服务装置;所述MySQL服务装置将接收的所述推送数据进行持久化操作,即存储在磁盘存储设备中;所述热点数据缓存服务装置根据其配置文件对所述推送数据进行过滤处理,并将过滤后的需要存储的数据存储在所述热点数据缓存服务装置中。
-
公开(公告)号:CN110493342A
公开(公告)日:2019-11-22
申请号:CN201910775315.6
申请日:2019-08-21
Applicant: 北京明朝万达科技股份有限公司
Abstract: 本申请实施例提供了一种文件传输方法、装置、电子设备及可读存储介质,所述方法应用于文件传输系统,所述文件传输系统包括发送端和接收端,所述方法包括:在所述发送端获取待传输文件,确定传输所述待传输文件所需的多个第一线程;所述发送端根据所述多个第一线程,将所述待传输文件分割成多个文件块;所述发送端将所述多个文件块异步传输至kafka中;所述接收端采用预置的线程池中的多个第二线程,异步读取对应的文件块;其中,所述多个第二线程与所述多个第一线程的数量相同;所述接收端根据读取的每个文件块中的文件位置指针,将所述每个文件块写入对应的文件位置,完成文件的传输;以提高文件传输的速度和稳定性。
-
-
-
-
-
-
-
-