Page 37 - 电力与能源2021年第五期
P. 37

吴程楠, 等: 基于电力调控特点及业务需求的增量数据实时同步技术研究                                  5 9
                                                                                                      2
              过此功能, 将 EMS 和 EP M 中变电站内的出线                      唤醒将变化传递到目标数据库; 基于日志法是通
                                     3
              开关进行匹配, 在 EP M 系统中建立模型映射关                        过分析数据库日志信息来捕获同步对象的变化序
                                 3
              系。本文中的功能实现需使用 EMS 数据接口,                          列; 基于快照法是指数据库中存储对象在某一时
              在配网模型增量同步的配电设备结构中的每种设                            刻的即时映像, 通过为同步对象定义一个快照或
              备都需要新增错误码属性( ErrorCode )。同步线                     采用类似方法将它的当前映像作为更新副本; 基
              路失败时, 将根据此错误码做出某些动作, 便于下                         于 API法是指在应用程序和数据库之间引入中
              次同步。                                             间件, 由它提供一系列 API , 在完成应用程序对数
              3.2  基于增量数据的实时同步需求分析                             据库修改的同时, 也把同步对象的变化序列记录
                  EP M 通过调度日计划模块实现与规划业务                        下来从而达到捕获的目的。
                     3
              模块的贯通。同时通过数据同步将相关模型同步                                基于触发器的结构化语言( SQL ) 文件级             [ 3 ] 异
              EMS 中, 在 EMS 实现日计划确认及发布, 从而将                     构数据库同步方法的基本思想就是为源数据库创
              EMS系统也作为电力生产业务流程中的节点, 实                          建触发器, 当源数据库发生变化时, 触发器在变更
              现以“ 调” 定贯通的“ 用数字资产促动实物资产精                        表中通过 SQL 语句的重组记录目标库能够直接
              细化管理” 总体建设目标, 确保数字电网与物理电                         执行的 SQL 语句, 然后将 SQL 语句定时导出到
              网保持 100% 同步。                                     文件, 并通过网闸将文件传输到目标端, 目标库定
                   调度日计划在 EP M 生成后, 经过运方专员                     时执行 SQL 文件将源库中的变更数据更新到目标
                                  3
              审核后进入 EMS , EMS 需从 EP M 中获取日计                    库, 同时再将执行完结果状态向源数据库端反馈,
                                            3
              划许可、 汇报信息及其关联的图形异动信息, 自动                         针对同步过程中出现的不同失败状态采取不同措
              化专员完成厂站联调后调度员可对需发布图形的                            施, 以实现整个数据同步过程的故障定位与恢复。
              日计划进行图形发布, 并将相关图形异动消息返                               实时数据基于用户数据报协议 ( UDP ) 消息
              回 EP M 。实 现 EP M 、 EMS 图 模 的 同 源 维 护。            机制发送, 商用数据库基于结构化 SQL 文件机制
                   3
                                3
              EP M 录入日计划并抽取增量变化图形和模型,                          实现。当 ModelModif yServer接受应用程序操
                 3
              通过日计划模块同步到 EMS 镜像管理信息大区                          作请求后, 首先向源端商用数据库处理服务 S q l-
              日计划模块中, 根据设备增量变化情况生成红图                          S pServer提交操作, 并生成结构化的 SQL 语句,
              模型和图形, 并通过 EMS 图模同步机制自动同                         以文件形式存储于服务器, 以 Session _ id+times-
              步到生产控制大区。                                       tam p 进行编号, S q lS pServer 异步按顺 序 执 行,
                   自动化专员在生产控制大区生成红图设备前                         执行成功的 SQL 以 1s或 128 个 SQL 文件为单
              置信息, 该前置信息不同步到管理信息大区, 调试                         位生成时间戳 + ( 128 个实际 SQL 数量) 的 List
              专员在生产控制大区红图态下完成厂站联调。调                           Se q 文件在对应的 SQL 文件全部发送后, 传至目
              度员停送电操作当天, 由调度员在管理信息大区                           标端 数 据 库 服 务 器; 目 标 端 数 据 库 服 务 器 收 到
              完成调度日计划发布, EMS 在管理信息大区镜像                        ListSe q 后, 按照清单依次执行结构化的 SQL , 从
              系统将红图的图模改为投运状态, 并通过图模同                          List中去除该 SQL , 形成处理校核结果更新 List
              步机制自动同步到生产控制大区。在红图投运同                           Se q 执 行 完 成 后 将 List 通 过 正 向 隔 离 返 回 给
                                                                  ,
              时, 发送日计划发布消息给 EP M , EP M 完成地                   S q lS pServer , 三区 S q lS p 检查如有缺失则启动补
                                                3
                                          3
              理图到 EMS 地理图的更新。                                  发, 直至一区返回全部处理成功的 ListSe q 三区
                                                                                                     ,
                                                               移除该 ListSe q 表示一个完整周期完成。
                                                                             ,
              4  增量数据实时处理技术
                                                                   安全一 / 三区实时库与商用库分别有数据比
                   增量数据同步捕获图模变化作为数据库系统                         较与同步服务持续比较实时库和商用库数据一致
              层面数据同步的基础, 其方法包括以下几种                    [ 1-2 ] :  性情况。安全一区、 三区分别以本区商用库为基
              基于触发器法、 基于快照法、 基于日志法、 基于应                        准, 如发现数据不一致, 则强制利用商用库数据向
              用程序接口( API ) 法等。基于触发器法是在源数                       实时库同步, 确保本端数据一致。
              据库为同步对象创建触发器, 当对同步对象进行                               以表为基本单位进行跨区商用库、 实时库数
              增删改等数据操纵语言( DML ) 命令时, 触发器被                      据同步, 确定需要进行数据同步的设备表及参数
   32   33   34   35   36   37   38   39   40   41   42