一种数据处理方法、装置、电子设备和存储介质

    公开(公告)号:CN113254466B

    公开(公告)日:2022-03-01

    申请号:CN202110682370.8

    申请日:2021-06-18

    Abstract: 本申请涉及计算机技术领域,尤其涉及一种数据处理方法、装置、电子设备和存储介质,用以提高数据存储的安全性和数据处理效率。其中,方法包括:通过事件收集模块从第一数据库中批量获取采样数据;将获得的采样数据写入消息队列,并通过消息队列向事件分发模块推送基于采样数据生成的数据变更消息;通过事件分发模块将数据变更消息映射为业务事件,并存储至事件池中;接收到消息获取方发送的事件获取请求时,基于事件获取请求中的索引信息,从事件池中获取与索引信息对应的业务事件并发送至消息获取方。本申请解除业务模块的耦合,引入事件中心机制,基于事件中心机制统一对象事件管理,提高了数据存储的安全性和数据处理效率。

    一种数据处理方法、装置、电子设备和存储介质

    公开(公告)号:CN113254466A

    公开(公告)日:2021-08-13

    申请号:CN202110682370.8

    申请日:2021-06-18

    Abstract: 本申请涉及计算机技术领域,尤其涉及一种数据处理方法、装置、电子设备和存储介质,用以提高数据存储的安全性和数据处理效率。其中,方法包括:通过事件收集模块从第一数据库中批量获取采样数据;将获得的采样数据写入消息队列,并通过消息队列向事件分发模块推送基于采样数据生成的数据变更消息;通过事件分发模块将数据变更消息映射为业务事件,并存储至事件池中;接收到消息获取方发送的事件获取请求时,基于事件获取请求中的索引信息,从事件池中获取与索引信息对应的业务事件并发送至消息获取方。本申请解除业务模块的耦合,引入事件中心机制,基于事件中心机制统一对象事件管理,提高了数据存储的安全性和数据处理效率。

    一种业务变更消息的处理方法及装置

    公开(公告)号:CN114422577A

    公开(公告)日:2022-04-29

    申请号:CN202011083983.1

    申请日:2020-10-12

    Abstract: 本申请实施例提供了一种业务变更消息的处理方法及装置,涉及云技术领域,该方法包括:云服务器接收到携带业务变更消息的业务变更请求时,将业务变更消息写入持久化消息队列,持久化消息队列位于服务器的非易失存储介质中,且持久化消息队列中的业务变更消息备份保存在非易失存储介质中。从持久化消息队列中获取业务变更消息,并将业务变更消息的消息标识写入消息中间件。通过消息中间件将消息标识推送给消息订阅端,以使消息订阅端基于消息标识从非易失存储介质中获取对应的业务变更消息。由于持久化消息队列位于服务器的非易失存储介质中,且通过持久化消息队列将业务变更消息备份保存在服务器的非易失存储介质,从而避免了业务变更消息丢失。

    一种内容流处理方法、装置、设备及介质

    公开(公告)号:CN110673962A

    公开(公告)日:2020-01-10

    申请号:CN201910794944.3

    申请日:2019-08-27

    Abstract: 本发明公开了一种内容流处理方法、装置、设备及介质,所述方法包括获取待处理的原始内容,为所述原始内容生成其对应的内容对象,将所述内容对象存储于预设的存储空间;在所述存储空间中获取目标内容对象;获取所述目标内容对象关联的至少一个业务,根据所述业务获取其对应的微服务调用拓扑,以得到所述目标内容对象对应的微服务调用拓扑集;根据所述微服务调用拓扑集中的各个微服务调用拓扑并发地调用相关微服务对所述目标内容对象进行流处理,将流处理过程中产生的调用关联信息存入所述目标内容对象;从所述目标内容对象中得到所述目标内容对象关联的业务输出对象。本发明可以同时满足多个业务的流处理要求,以得到各个业务所需的流处理结果。

    一种内容流处理方法、装置、设备及介质

    公开(公告)号:CN110673962B

    公开(公告)日:2024-06-14

    申请号:CN201910794944.3

    申请日:2019-08-27

    Abstract: 本发明公开了一种内容流处理方法、装置、设备及介质,所述方法包括获取待处理的原始内容,为所述原始内容生成其对应的内容对象,将所述内容对象存储于预设的存储空间;在所述存储空间中获取目标内容对象;获取所述目标内容对象关联的至少一个业务,根据所述业务获取其对应的微服务调用拓扑,以得到所述目标内容对象对应的微服务调用拓扑集;根据所述微服务调用拓扑集中的各个微服务调用拓扑并发地调用相关微服务对所述目标内容对象进行流处理,将流处理过程中产生的调用关联信息存入所述目标内容对象;从所述目标内容对象中得到所述目标内容对象关联的业务输出对象。本发明可以同时满足多个业务的流处理要求,以得到各个业务所需的流处理结果。

    业务处理频率的控制方法、系统、装置、电子设备

    公开(公告)号:CN111897659B

    公开(公告)日:2020-12-25

    申请号:CN202011045773.3

    申请日:2020-09-29

    Abstract: 本发明实施例公开了一种业务处理频率的控制方法、系统、装置、电子设备,可应用于云服务的业务处理领域;在本发明实施例中,服务器可获取并基于用户配置频率和上一时刻的令牌数量确定当前时刻的令牌数量,根据当前时刻的令牌数量和从客户端获取到的目标业务的请求积累量计算惩罚时段,并将惩罚时段发送给客户端;当当前时刻在惩罚时段内时,客户端可告知目标业务拒绝接收业务请求,当当前时刻在惩罚时段外时,客户端可告知目标业务接收业务请求。在本方案中,客户端通过网络将业务的请求积累量发送给服务器,使得服务器根据请求积累量给该客户端返回惩罚时段,从而实现基于惩罚时段的业务流量控制。由此,本方案可以提升业务处理频率的控制效率。

    业务处理频率的控制方法、系统、装置、电子设备

    公开(公告)号:CN111897659A

    公开(公告)日:2020-11-06

    申请号:CN202011045773.3

    申请日:2020-09-29

    Abstract: 本发明实施例公开了一种业务处理频率的控制方法、系统、装置、电子设备,可应用于云服务的业务处理领域;在本发明实施例中,服务器可获取并基于用户配置频率和上一时刻的令牌数量确定当前时刻的令牌数量,根据当前时刻的令牌数量和从客户端获取到的目标业务的请求积累量计算惩罚时间,并将惩罚时间发送给客户端;当当前时刻在惩罚时段内时,客户端可告知目标业务拒绝接收业务请求,当当前时刻在惩罚时段外时,客户端可告知目标业务接收业务请求。在本方案中,客户端通过网络将业务的请求积累量发送给服务器,使得服务器根据请求积累量给该客户端返回惩罚时间,从而实现基于惩罚时间的业务流量控制。由此,本方案可以提升业务处理频率的控制效率。

Patent Agency Ranking