用于流式计算的规则更新方法、装置及流式计算系统

    公开(公告)号:CN111221550A

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

    申请号:CN201911018140.0

    申请日:2019-10-24

    Inventor: 邬浩艳 尹攀

    Abstract: 本说明书的实施例提供用于流式计算的规则更新方法、装置及流式计算系统。该流式计算系统包括规则配置平台、规则管理器、分布式文件服务器、任务调度器、资源管理器和至少一个任务执行器节点。任务调度器定期向规则管理器发送增量更新规则查询请求。规则管理器响应于增量更新规则查询请求而从规则配置平台获取规则列表数据。任务调度器使用规则列表数据中的文件存储路径地址,获取进入上线状态的增量更新业务规则的可执行文件。任务调度器基于增量更新业务规则的可执行文件构建规则执行器实例,并将所构建的规则执行器实例广播给各个任务执行器节点以进行规则执行器更新。各个任务执行器节点使用更新后的规则执行器来运行后续任务。

    业务数据的计算方法和装置

    公开(公告)号:CN112925663A

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

    申请号:CN202110317810.X

    申请日:2021-03-25

    Inventor: 李亮 尹攀 邬浩艳

    Abstract: 本说明书实施例提供了业务数据的计算方法和装置。首先,在业务进行过程中,获取业务数据;并且,在业务进行过程中,监测阶段计算触发事件;当监测到阶段计算触发事件后,利用在当前阶段中获取的业务数据进行当前阶段的特征计算;其中,在第一次监测到阶段计算触发事件时,所述当前阶段为:从所述业务开始时至当前第一次监测到阶段计算触发事件之间的阶段;在非第一次监测到阶段计算触发事件时,所述当前阶段为:上一次监测到阶段计算触发事件至当前监测到阶段计算触发事件之间的阶段;利用各阶段的特征计算结果,得到所述业务对应的业务计算结果。

    多阶段灰度验证方法、装置、电子设备及介质

    公开(公告)号:CN111767060A

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

    申请号:CN202010423178.2

    申请日:2020-05-19

    Inventor: 邬浩艳 尹攀

    Abstract: 本说明书实施例公开了一种多阶段灰度验证方法,在无固定用户标识场景下,接收用户进行业务操作的操作请求;若检测到所述操作请求为所述业务操作的首次请求,获取所述业务操作对应的唯一操作标识,为所述业务操作生成一随机数,并将所述唯一操作标识和所述随机数对应后缓存;以及将所述业务操作的后续每次操作请求中写入所述随机数;针对所述业务操作的所有操作请求,根据所述随机数和灰度发布的分流规则,确定所述业务操作对应的目标版本,其中,所述目标版本为原始版本和灰度发布版本中的任意一个。

    业务数据的计算方法和装置

    公开(公告)号:CN112925663B

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

    申请号:CN202110317810.X

    申请日:2021-03-25

    Inventor: 李亮 尹攀 邬浩艳

    Abstract: 本说明书实施例提供了业务数据的计算方法和装置。首先,在业务进行过程中,获取业务数据;并且,在业务进行过程中,监测阶段计算触发事件;当监测到阶段计算触发事件后,利用在当前阶段中获取的业务数据进行当前阶段的特征计算;其中,在第一次监测到阶段计算触发事件时,所述当前阶段为:从所述业务开始时至当前第一次监测到阶段计算触发事件之间的阶段;在非第一次监测到阶段计算触发事件时,所述当前阶段为:上一次监测到阶段计算触发事件至当前监测到阶段计算触发事件之间的阶段;利用各阶段的特征计算结果,得到所述业务对应的业务计算结果。

    用于流式计算的规则更新方法、装置及流式计算系统

    公开(公告)号:CN111221550B

    公开(公告)日:2022-09-06

    申请号:CN201911018140.0

    申请日:2019-10-24

    Inventor: 邬浩艳 尹攀

    Abstract: 本说明书的实施例提供用于流式计算的规则更新方法、装置及流式计算系统。该流式计算系统包括规则配置平台、规则管理器、分布式文件服务器、任务调度器、资源管理器和至少一个任务执行器节点。任务调度器定期向规则管理器发送增量更新规则查询请求。规则管理器响应于增量更新规则查询请求而从规则配置平台获取规则列表数据。任务调度器使用规则列表数据中的文件存储路径地址,获取进入上线状态的增量更新业务规则的可执行文件。任务调度器基于增量更新业务规则的可执行文件构建规则执行器实例,并将所构建的规则执行器实例广播给各个任务执行器节点以进行规则执行器更新。各个任务执行器节点使用更新后的规则执行器来运行后续任务。

Patent Agency Ranking