-
公开(公告)号:CN110827072A
公开(公告)日:2020-02-21
申请号:CN201911052330.4
申请日:2019-10-31
Applicant: 支付宝(杭州)信息技术有限公司
IPC: G06Q30/02 , G06F16/22 , G06F16/248
Abstract: 本申请公开了一种数据查询、存储方法及系统。数据存储方法包括:当约定事件被触发时,从存储设备读取一个位图,其中,每一个所述位图用于存储一段时间内所述约定事件被触发的信息,所述位图中每一个比特位对应在一个约定时间所述约定事件是否被触发;根据所述约定事件被触发的时间计算需要操作的比特位在所述位图中的位置,将所述位图中该位置的比特位设置为代表所述约定事件被触发的值;将修改后的位图写回所述存储设备,替换修改前的位图。
-
公开(公告)号:CN112015561B
公开(公告)日:2024-07-30
申请号:CN202010974346.7
申请日:2020-09-16
Applicant: 支付宝(杭州)信息技术有限公司
Abstract: 本说明书的实施例提供了用于流式计算服务的方法、装置、计算设备、机器可读存储介质和系统。该方法包括:确定待分配的M个消息队列分区;基于一致性哈希算法,将M个消息队列分区映射到一致性哈希环上;基于M个消息队列分区的映射结果,将M个消息队列分区分别分配给流式计算集群中的N个计算节点中的相应的计算节点,以便由相应的计算节点处理相应的消息队列分区中的消息,其中,N个计算节点基于一致性哈希算法被映射到一致性哈希环上。
-
公开(公告)号:CN112015561A
公开(公告)日:2020-12-01
申请号:CN202010974346.7
申请日:2020-09-16
Applicant: 支付宝(杭州)信息技术有限公司
Abstract: 本说明书的实施例提供了用于流式计算服务的方法、装置、计算设备、机器可读存储介质和系统。该方法包括:确定待分配的M个消息队列分区;基于一致性哈希算法,将M个消息队列分区映射到一致性哈希环上;基于M个消息队列分区的映射结果,将M个消息队列分区分别分配给流式计算集群中的N个计算节点中的相应的计算节点,以便由相应的计算节点处理相应的消息队列分区中的消息,其中,N个计算节点基于一致性哈希算法被映射到一致性哈希环上。
-
公开(公告)号:CN115033603B
公开(公告)日:2025-01-24
申请号:CN202210679957.8
申请日:2022-06-16
Applicant: 支付宝(杭州)信息技术有限公司
Inventor: 连文珑
IPC: G06F16/2455 , G06F16/22 , G06Q20/08
Abstract: 本说明书实施例提供了一种数据存储、数据查询方法及装置。前端节点可以对写入请求或查询请求进行路由分发,使得同一主体的请求分发给同一服务器节点。服务器节点在本地的存储单元中存储最近一段时间的聚合后的细粒度数据,一方面提升吞吐量,一方面降低查询耗时。并且,将存储单元中的数据备份在数据存储平台中。将业务跨度比较大的更早的冷数据,也就是聚合后的粗粒度数据存储在数据存储平台中。因此,查询时的热数据直接在本地的存储单元中读取,而查询时覆盖到的冷数据可以到数据存储平台中捞取数据。
-
公开(公告)号:CN115033603A
公开(公告)日:2022-09-09
申请号:CN202210679957.8
申请日:2022-06-16
Applicant: 支付宝(杭州)信息技术有限公司
Inventor: 连文珑
IPC: G06F16/2455 , G06F16/22 , G06Q20/08
Abstract: 本说明书实施例提供了一种数据存储、数据查询方法及装置。前端节点可以对写入请求或查询请求进行路由分发,使得同一主体的请求分发给同一服务器节点。服务器节点在本地的存储单元中存储最近一段时间的聚合后的细粒度数据,一方面提升吞吐量,一方面降低查询耗时。并且,将存储单元中的数据备份在数据存储平台中。将业务跨度比较大的更早的冷数据,也就是聚合后的粗粒度数据存储在数据存储平台中。因此,查询时的热数据直接在本地的存储单元中读取,而查询时覆盖到的冷数据可以到数据存储平台中捞取数据。
-
-
-
-