(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210432581.0 (22)申请日 2022.04.20 (71)申请人 北京云集智造科技有限公司 地址 100000 北京市朝阳区来广营西路5号 院5号楼5层5 06室 (72)发明人 薛明　杨好颖　朱品燕　 (51)Int.Cl. G06F 16/28(2019.01) G06F 16/22(2019.01) G06F 16/2455(2019.01) (54)发明名称 基于可视化编排AIOps数据接入和处理的方 法和装置 (57)摘要 本发明公开了基于可视化编排AIOps数据接 入和处理的方法和装置， 涉及AIOps数据接入和 处理技术领域； 为了解决AIOps数据接入的难度 大、 效率低的问题； 该方法， 包括以下步骤： 将IT 系统运维数据的接入和处理过程组成一系列相 互连接的数据命令单元； 利用数据连接将相邻两 个数据命令 单元进行桥接。 该装置， 包括基于Web 或本地图形化程序的用户界面、 对提交的有向无 环组进行调度和执行的DAG执行引擎、 数据分片 数据库、 存储有所有关于数据分片的描述性数据 和状态转换信息的元数据库。 本发明有效降低 AIOps系统的构建和实施人员的技术要求， 可快 速高效地支持AI Ops系统所需的各种运维数据接 入和处理任务。 权利要求书2页 说明书6页 附图2页 CN 114840610 A 2022.08.02 CN 114840610 A 1.基于可视化编排AIOps数据接入和处 理的方法， 其特 征在于， 包括以下步骤： S1： 将IT系统运维数据的接入和处 理过程组成一系列相互连接的数据命令单 元； S2： 利用数据连接将相邻两个数据命令单 元进行桥接； S3： 由一系列数据命令单 元和数据连接共同搭建整个有向无环组； S4： 数据命令单 元处理数据分片， 并通过 数据连接进行传递， 在有向无环组中流 转； S5： 将一系列通过数据连接相互关联的数据命令单元定义为子流程， 把子流程作为一 个独立的新数据命令单 元进行复用； 所述数据命令单 元包括O‑N个输入端口和O ‑N个输出端口。 2.根据权利要求1所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述数据分片包含数据内容和两个以上的数据属性值， 数据内容为结构化和非结构化中的 一种， 数据属性 值为一系列键值对， 包括日志数据来源、 时段、 模块名称。 3.根据权利要求1所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述数据命令单元包括用于从有向无环组外部获取各种IT系统运 维数据的输入模块、 用于 对输入的数据分片按顺序完成一系列命令操作的序列模块、 用于对输入的数据分片完成一 系列可循环命令操作的迭代模块、 选择模块和用于输出数据分片 至外部系统工作的输出模 块。 4.根据权利要求3所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述输入模块包括日志数据、 系统监控 数据、 应用监控数据、 告警数据、 调用链数据、 静态配 置数据、 自定义事 件数据； 所述输入 模块的输入方式包括文件上传、 网络协议、 应用协议、 数据库访问、 API访问； 所述输出模块和输入 模块均属于单向命令处 理模块。 5.根据权利要求4所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述序列模块用于对接 收的数据分片进行不同处理策略， 所述不同处理策略， 具体包括以 下类型： Aa： 对每个输入的数据分片完成整个序列模块的命令处 理后， 再接收下一个数据分片； Ab： 将数据连接中的所有数据分片集结为一个批次N1， 将N1交由序列模块进行处理， 完 成后再读取N2. ..Nn； Ac： 无限循环读取输入的数据分片， 直接交由序列模块处 理。 6.根据权利要求5所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述迭代模块用于将处理完成的数据分片 输入进行新一轮的处理， 且迭代模块的每次处理 结果和过程数据均会被记录 至数据分片的内容或属性中； 所述迭代模块的迭代次数或迭代条件通过参数进行配置 。 7.根据权利要求6所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述选择模块的工作方法， 包括以下内容： B1： 选择在两个或两个以上的数据命令单 元中对输入数据分片进行命令操作； B2： 只完成其中一个数据命令单 元的命令处 理。 8.根据权利要求2所述的基于可视化编排AIOps数据接入和处理的方法， 其特征在于， 所述数据连接包括用于存 储待处理数据分片的数据缓冲区。 9.基于可视化编排AIOps数据接入和处理的装置， 包括基于Web或本地图形化程序的用权　利　要　求　书 1/2 页 2 CN 114840610 A 2户界面、 对提交的有向无环组进行调度和执行的DAG执行引擎、 数据分片数据库、 存储有所 有关于数据分片的描述性数据和状态转换信息的元数据库， 其特征在于， 所述用户界面为 用户通过可视化地拖拽方式完成数据命令单元和数据连接， 用户界面显示数据分片 被处理 的状态和观察数据结果； 所述DAG执 行引擎为单机或分布式 中的一种。 10.根据权利要求9所述的基于可视化编排AIOps数据接入和处理的装置， 其特征在于， 所述数据分片数据库的职责为： 存储数据分片的具体内容， 并提供查询接口给DAG执行引 擎； 所述数据分片数据库可支持不同存 储格式类型的数据。权　利　要　求　书 2/2 页 3 CN 114840610 A 3