基于统一轮次标识的异步筛选级联一致性调度方法及装置与流程

摘要: 本技术涉及数据分析领域,特别是涉及一种基于统一轮次标识的异步筛选级联一致性调度方法及装置。背景技术:1、数据分析类系统通常在一个界面中同时布置多个筛选控件和多个...
基于统一轮次标识的异步筛选级联一致性调度方法及装置与流程

本技术涉及数据分析领域,特别是涉及一种基于统一轮次标识的异步筛选级联一致性调度方法及装置。

背景技术:

1、数据分析类系统通常在一个界面中同时布置多个筛选控件和多个数据展示组件。筛选控件之间存在值的依赖与联动关系,例如一个控件的可选值受另一个控件当前取值的影响,而多个筛选控件的取值结果又会共同作用于若干数据展示组件。当用户在短时间内连续修改筛选条件、由软件开发工具包批量写入条件,或者系统在初始化阶段执行多批次求值时,多个筛选节点便会并行或先后发起异步请求,形成一条条相互交织的级联更新链路。在这种复杂交互环境下,如何保证最终展示的数据与用户最新设定的筛选条件保持一致,是数据分析系统需要解决的重要问题。

2、现有技术已能对可联动面板、控件依赖和事件传播进行描述。例如,部分方案通过维护模块之间的依赖关系和状态节点,实现了依赖传播与编排;另有方案能够对面板间的动态联动事件进行分发。这些方案为依赖关系的表达和事件的传播奠定了基础,但大多侧重于“如何将变化沿依赖链传播”,而在数据分析界面的异步筛选场景中,往往缺少对同一业务轮次、递归上游稳定性、级联前沿以及数据库查询释放条件的统一控制,难以同时兼顾并发效率与结果一致性。

3、具体而言,若下游筛选节点仅等待其直接上游完成求值,而更上游的较新求值尚未结束,则下游节点会在输入条件尚未最终稳定时被提前触发,产生无效的中间态求值;若对所有受影响节点同时发起继续求值,则同一依赖路径上的多个节点会被重复调度,造成冗余请求;若数据展示节点在筛选级联尚未稳定时即发起数据库查询,则会生成大量无效请求、引起界面闪动,甚至出现较早返回的查询结果覆盖较新状态的错误。虽然已有方案采用请求取消或结果丢弃等手段避免旧值覆盖,但请求取消只能处理单个节点自身的过期请求,无法解决不同依赖分支之间“何谓稳定、何时可继续”的统一判断问题。

4、因此,亟需一种面向异步筛选级联的调度机制,在保留异步并发能力的同时,能够为一次业务触发建立可比较的时序基准,识别同一轮次内各级上游的稳定状态,选择正确的继续调度入口,并把数据库查询推迟到相关上游全部稳定之后再进行,从而减少中间态查询、重复请求与旧结果覆盖,提高数据展示结果的一致性。

技术实现思路

1、本技术实施例提供了一种基于统一轮次标识的异步筛选级联一致性调度方法,本方案对每次外部触发生成的求值事件分配单调递增或时间戳形式的轮次标识,异步求值结果携带对应轮次标识,仅当与节点当前轮次一致时才被应用,否则直接丢弃,而级联产生的新求值事件继承原轮次标识,从而为一次业务触发建立可比较的时序基准,避免同一时间单位内不同事件碰撞,从节点层面丢弃过期请求的返回结果,防止旧轮次值覆盖新状态,保证结果一致性。

2、第一方面,本技术实施例提供了一种基于统一轮次标识的异步筛选级联一致性调度方法,所述方法包括:

3、s1、基于数据分析界面构建有向依赖图,所述有向依赖图的节点包括筛选节点、数据展示节点,边为不同节点之间的求值影响关系,每一筛选节点实时维护求值版本字段以及求值状态字段;

4、s2、目标筛选节点响应于筛选求值事件,并生成筛选求值事件的轮次标识,基于筛选求值事件对目标筛选节点进行异步求值得到异步求值结果,目标筛选节点的求值版本字段记录对应筛选求值事件的轮次标识,求值状态字段记录异步求值的进行状态;

5、s3、目标筛选节点应用异步求值结果,基于有向依赖图中的求值影响关系获取与目标筛选节点对应的多个候选筛选节点,将通过上游稳定性检查的候选筛选节点作为稳定筛选节点,并将不受另一稳定筛选节点的求值结果影响的稳定筛选节点作为级联前沿节点,并基于目标筛选节点的异步求值结果为每一级联前沿节点发送新的筛选求值事件,其中,以目标筛选节点应用异步求值结果所触发的求值事件作为新的筛选求值事件,且新的筛选求值事件继承目标筛选节点所响应筛选求值事件的轮次标识;

6、s4、分别将各级联前沿节点作为新的目标筛选节点,并分别响应对应的新的筛选求值事件重复执行s2-s3;

7、s5、若在当前轮次标识下不存在级联前沿节点,则更新受筛选求值事件影响的数据展示节点的展示结果。

8、第二方面,本技术实施例提供了一种基于统一轮次标识的异步筛选级联一致性调度装置,包括:

9、构建模块,基于数据分析界面构建有向依赖图,所述有向依赖图的节点包括筛选节点、数据展示节点,边为不同节点之间的求值影响关系,每一筛选节点实时维护求值版本字段以及求值状态字段;

10、异步求值模块,目标筛选节点响应于筛选求值事件,并生成筛选求值事件的轮次标识,基于筛选求值事件对目标筛选节点进行异步求值得到异步求值结果,目标筛选节点的求值版本字段记录对应筛选求值事件的轮次标识,求值状态字段记录异步求值的进行状态;

11、应用模块,目标筛选节点应用异步求值结果,基于有向依赖图中的求值影响关系获取与目标筛选节点对应的多个候选筛选节点,将通过上游稳定性检查的候选筛选节点作为稳定筛选节点,并将不受另一稳定筛选节点的求值结果影响的稳定筛选节点作为级联前沿节点,并基于目标筛选节点的异步求值结果为每一级联前沿节点发送新的筛选求值事件,其中,以目标筛选节点应用异步求值结果所触发的求值事件作为新的筛选求值事件,且新的筛选求值事件继承目标筛选节点所响应筛选求值事件的轮次标识;

12、循环模块,分别将各级联前沿节点作为新的目标筛选节点,并分别响应对应的新的筛选求值事件返回异步求值模块;

13、数据展示模块,若在当前轮次标识下不存在级联前沿节点,则更新受筛选求值事件影响的数据展示节点的展示结果。

14、第三方面,本技术实施例提供了一种电子装置,包括存储器和处理器,所述存储器中存储有计算机程序,所述处理器被设置为运行所述计算机程序以执行一种基于统一轮次标识的异步筛选级联一致性调度方法。

15、本发明的主要贡献和创新点如下:

16、本技术实施例将数据分析界面中的筛选组件抽象为筛选节点、数据展示组件抽象为数据展示节点,以有向边表示筛选值依赖、筛选作用范围、动态参数引用等求值影响关系,完整表达各筛选控件与展示组件之间的联动关系,为后续级联调度提供全局结构依据,这两个字段为所有一致性判断提供了实时、统一的节点状态快照;本技术实施例对每次外部触发生成的求值事件分配单调递增或时间戳形式的轮次标识,异步求值结果携带对应轮次标识,仅当与节点当前轮次一致时才被应用,否则直接丢弃,而级联产生的新求值事件继承原轮次标识,从而为一次业务触发建立可比较的时序基准,避免同一时间单位内不同事件碰撞,从节点层面丢弃过期请求的返回结果,防止旧轮次值覆盖新状态,保证结果一致性;本技术实施例以目标筛选节点为起点沿下游获取存在求值影响关系的中间筛选节点,剔除不支持自动求值、作用域不同、以及求值版本字段晚于目标节点的节点,仅保留真正需要继续调度的节点,从而精确锁定受本次变更实际影响的节点,避免对无关或无需再次处理的节点发起调度,减少无效计算与冗余请求;本技术实施例对每一候选节点沿上游路径递归遍历,仅当其上游所有节点均不处于异步求值进行中、且求值版本字段不晚于当前候选节点时,才判定为稳定筛选节点并保留,否则移除,从而避免下游节点在输入条件尚未最终稳定时被提前触发,从根源上消除无效的中间态求值;本技术实施例在候选子图中找出稳定筛选节点之间的可达关系,移除可被另一稳定节点沿子图到达的节点,仅保留“级联前沿”作为直接调度入口,从而避免同一依赖路径上的前后节点被同时直接调度导致重复求值,实现“只调度最前端,后续由同轮次继续触发”的有序推进。

17、本技术的一个或多个实施例的细节在以下附图和描述中提出,以使本技术的其他特征、目的和优点更加简明易懂。