基于规则引擎的城市光纤传感事件策略边缘计算方法与流程

本发明涉及光纤传感事件策略边缘计算，具体为基于规则引擎的城市光纤传感事件策略边缘计算方法。

背景技术：

1、城市光纤传感事件策略边缘计算中，边缘节点需要根据光纤传感事件片段携带的光路通道标识确定对应策略并执行动作。现有技术通常在边缘节点配置规则列表或规则树，光纤传感事件到达后按事件条件逐条遍历，匹配成功后再调用动作。光路通道标识与策略的对应关系一般通过集中式配置或静态表项下发，规则条件与动作项多采用独立条目存储。城市光路和通道数量增多时，单次事件需要比对的规则条数上升，边缘节点匹配延迟增大，处理吞吐下降。规则更新时，现有方式多采用整体替换规则集或重新加载规则引擎，正在处理的事件在版本切换过程中可能混合使用新旧规则条件，导致动作触发结果不一致。结果回传时，动作触发结果与事件片段标识和规则版本缺少绑定，批量汇聚时难以区分事件来源、规则版本和批次。现有技术未提供根据光路通道标识快速定位规则条件的槽式结构，未提供条件槽依赖关系下的匹配状态传递机制，规则包版本变化时正在处理的事件难以保持使用一致的条件集合，动作触发结果未与事件片段标识绑定并按照批次汇聚。需要一种边缘计算方法，在边缘侧根据光路通道标识快速定位规则条件，在条件槽依赖关系下传递匹配状态，规则包版本变化时保持当前事件处理使用一致条件集合，动作触发结果与事件片段绑定后按批次汇聚。

技术实现思路

1、针对现有城市光纤传感事件策略边缘计算中规则逐条遍历匹配、规则更新时处理一致性不足以及结果批次汇聚不完善的问题，提供一种基于规则引擎的城市光纤传感事件策略边缘计算方法，通过光路通道标识映射策略槽位号，从本地规则库取出含条件槽、动作位和槽间依赖的边缘规则包，按槽间依赖传递槽值并生成动作触发位图，在规则包版本变化时通过版本随槽值向量传递和旧版本条件槽副本继续参与处理，并将动作触发位图与光纤传感事件片段绑定后写入边缘结果队列。

2、为了实现上述目的，本发明提供如下技术方案：基于规则引擎的城市光纤传感事件策略边缘计算方法，包括：

3、边缘节点接收光纤传感事件片段和光路通道标识，将所述光路通道标识映射为策略槽位号；

4、以所述策略槽位号从本地规则库取出含条件槽、动作位和槽间依赖的边缘规则包；

5、将所述光纤传感事件片段的时序特征写入所述条件槽，得到槽值向量；

6、按所述槽间依赖传递槽值，生成动作触发位图；

7、以所述动作触发位图调用边缘动作，输出事件策略结果；

8、将所述边缘规则包的版本随所述槽值向量传递，并将所述动作触发位图与所述光纤传感事件片段绑定后写入边缘结果队列。

9、优选的，所述将所述光路通道标识映射为策略槽位号，包括：

10、解析所述光路通道标识中的光路编号、通道编号和节点编号；

11、按所述节点编号查找边缘节点槽位表；

12、以所述光路编号和所述通道编号在所述边缘节点槽位表中定位连续槽段；

13、将所述连续槽段的首槽号作为所述策略槽位号，并将所述策略槽位号与所述光路通道标识写入同一槽位映射记录；

14、所述槽位映射记录随所述光纤传感事件片段进入所述本地规则库的取包步骤。

15、优选的，以所述策略槽位号从本地规则库取出含条件槽、动作位和槽间依赖的边缘规则包，按如下方式生成：

16、获取边缘策略条目中的条件项、动作项和策略标识；

17、将所述条件项按所述策略槽位号落入对应条件槽，得到条件槽索引；

18、将所述动作项绑定至所述动作位，并按所述策略标识建立所述条件槽索引与所述动作位之间的槽间依赖；

19、将所述条件槽索引、所述动作位和所述槽间依赖打包为所述边缘规则包，并为所述边缘规则包分配规则包版本；

20、所述规则包版本随所述边缘规则包写入所述本地规则库。

21、优选的，所述将所述光纤传感事件片段的时序特征写入所述条件槽，得到槽值向量，包括：

22、从所述光纤传感事件片段提取开始时刻、结束时刻、通道跨度和命中计数；

23、将所述开始时刻与所述结束时刻按边缘时基对齐，得到时窗索引；

24、将所述通道跨度映射为槽段长度，并将所述命中计数写入所述条件槽的计数值域；

25、按所述时窗索引和所述槽段长度排列所述条件槽，得到所述槽值向量。

26、优选的，所述按所述槽间依赖传递槽值，生成动作触发位图，包括：

27、读取所述槽间依赖中的源条件槽和目标条件槽；

28、以所述源条件槽的槽值触发所述目标条件槽的槽值更新；

29、在所述目标条件槽更新后，将所述目标条件槽关联的动作位写入位图缓存；

30、按所述槽间依赖的方向逐层传递，直至无新的动作位写入；

31、将所述位图缓存作为所述动作触发位图，并保留所述源条件槽与所述目标条件槽的传递路径标识。

32、优选的，所述以所述动作触发位图调用边缘动作，输出事件策略结果，包括：

33、读取所述动作触发位图中被置位的动作位；

34、以所述动作位查询边缘动作表，得到动作入口和结果字段模板；

35、按所述动作入口执行所述边缘动作，并从所述槽值向量读取动作参数；

36、将所述动作参数填入所述结果字段模板，生成事件策略结果；

37、将所述事件策略结果与所述边缘规则包的版本绑定后送入输出通道。

38、优选的，所述将所述边缘规则包的版本随所述槽值向量传递，包括：

39、在所述本地规则库更新所述边缘规则包时，生成新规则包版本和旧规则包版本；

40、将所述新规则包版本写入所述边缘规则包的版本字段；

41、当所述槽值向量进入所述条件槽时，将所述槽值向量携带的版本号与所述版本字段比对；

42、若所述版本号与所述版本字段不同，则将所述槽值向量绑定至所述旧规则包版本对应的条件槽副本；

43、所述条件槽副本继续参与所述槽间依赖的传递，并将所述新规则包版本写入所述事件策略结果。

44、优选的，所述将所述动作触发位图与所述光纤传感事件片段绑定后写入边缘结果队列，包括：

45、从所述光纤传感事件片段读取节点编号、光路编号、通道编号和批次号，组成事件片段标识；

46、将所述事件片段标识写入所述动作触发位图的头字段；

47、按所述头字段中的节点编号选择边缘结果队列；

48、将带有所述头字段的动作触发位图追加至所述边缘结果队列的队尾；

49、当所述边缘结果队列达到批量阈值时，按所述批次号将多个所述动作触发位图合并为边缘策略批次包。

50、优选的，所述光纤传感事件片段，按如下方式形成：

51、边缘采集接口从光纤传感设备读取原始帧，按光路通道标识将所述原始帧切分为通道帧；

52、在所述通道帧上标记帧到达时刻和帧序号；

53、将同一所述光路通道标识下连续帧序号且帧到达时刻落入同一时窗的通道帧聚合为候选片段；

54、从所述候选片段中提取幅度变化区间和持续时间；

55、将所述幅度变化区间和所述持续时间满足事件触发条件的候选片段作为所述光纤传感事件片段；

56、所述光纤传感事件片段携带所述光路通道标识进入所述边缘节点。

57、优选的，所述边缘节点接收光纤传感事件片段和光路通道标识，包括：

58、在所述边缘节点设置规则引擎容器和共享内存区；

59、所述规则引擎容器监听边缘采集接口，并在收到所述光纤传感事件片段时申请所述共享内存区的槽位；

60、将所述光纤传感事件片段写入所述共享内存区的数据段，将所述光路通道标识写入所述共享内存区的索引段；

61、从所述索引段读取所述光路通道标识并送入所述策略槽位号的映射步骤；

62、所述数据段与所述索引段通过槽位号关联，并在所述事件策略结果输出后释放所述槽位。

63、在上述技术方案中，本发明提供的技术效果和优点：

64、通过光路通道标识映射策略槽位号，从本地规则库取出含条件槽、动作位和槽间依赖的边缘规则包，光纤传感事件片段的开始时刻、结束时刻、通道跨度和命中计数等时序特征写入条件槽，形成槽值向量，源条件槽的槽值按槽间依赖触发目标条件槽更新，目标条件槽关联的动作位写入位图缓存，沿依赖方向逐层传递后生成动作触发位图。该方式将规则条件组织为条件槽索引，动作项绑定至动作位，条件槽之间的依赖关系确定匹配状态传递路径，替代对规则条目的逐条遍历匹配，动作触发位图在一次传递过程中同时表示多个动作触发状态，减少边缘节点在光路通道数量增加时的匹配计算量，缩短事件到达至动作调用之间的延迟，并保留传递路径标识，使动作触发结果与匹配路径保持对应。规则包版本随槽值向量传递，本地规则库更新边缘规则包时生成新规则包版本和旧规则包版本，槽值向量进入条件槽时将携带的版本号与版本字段比对，版本号不同则将槽值向量绑定至旧规则包版本对应的条件槽副本，条件槽副本继续参与槽间依赖传递，并将新规则包版本写入事件策略结果。该方式使规则更新期间已经进入处理流程的事件继续使用旧版本条件槽集合完成匹配，避免规则切换造成条件判断前后不一致和动作触发错误，规则版本信息随事件策略结果输出。动作触发位图与光纤传感事件片段的事件片段标识绑定，按节点编号写入边缘结果队列，达到批量阈值时按批次号合并为边缘策略批次包，降低结果回传和汇聚开销，可按规则版本和批次号追踪事件策略结果。