技术摘要:
本申请公开了一种物联网中的数据分析任务创建方法、装置及存储介质,涉及物联网技术领域。所述方法包括:显示可视化的数据分析任务的创建界面,该创建界面上显示有算子备选区以及算子编辑区,响应于接收到基于算子编辑区对至少两个目标数据处理算子的用户操作,根据用 全部
背景技术:
随着物联网技术的大规模普及,物与物、人与物之间的信息交互日趋频繁,在信息 交互的过程中,往往有许多数据源连续产生的数据汇集数据分析平台,以对这些数据进行 分析,这些数据称为流数据。 在相关技术中,物联网数据分析平台的搭建往往需要很长的开发和调试周期,需 要专业的开发人员通过开发者的工具构建数据分析任务,以实现对流数据的分析。 然而,在上述相关技术中,由于开发者工具的使用,需要开发者具有较为专业的代 码编辑能力,需要较长时间的知识学习和经验积累才能顺利完成该平台搭建的过程,限制 了数据分析任务的开发效率。
技术实现要素:
本申请实施例提供了一种物联网中的数据分析任务创建方法、装置及存储介质, 能够简化物联网场景下的数据分析任务的开发进程,满足普通用户对数据分析任务进行可 视化开发的需求。所述技术方案如下: 一方面,提供了一种物联网中的数据分析任务创建方法,所述方法包括: 显示可视化的数据分析任务的创建界面,所述创建界面上显示有算子备选区以及 算子编辑区,所述算子备选区提供有n种数据处理算子,n为正整数,所述数据处理算子用于 按照对应的分析逻辑对输入的数据进行处理,其中,所述数据是能源类物联网设备输入的 数据; 响应于接收到基于所述算子编辑区对至少两个目标数据处理算子的用户操作,根 据所述用户操作对所述目标数据处理算子进行编辑,得到各个所述目标数据处理算子的执 行顺序和执行参数,所述目标数据处理算子是所述n种数据处理算子中被选择的数据处理 算子; 根据各个所述目标数据处理算子的执行顺序和执行参数生成数据分析任务。 另一方面,提供了一种物联网中的数据分析任务创建装置,所述装置包括: 显示模块,用于显示可视化的数据分析任务的创建界面,所述创建界面上显示有 算子备选区以及算子编辑区,所述算子备选区提供有n种数据处理算子,n为正整数,所述数 据处理算子用于按照对应的处理逻辑对输入的数据进行处理,其中,所述数据是能源类物 联网设备输入的数据; 编辑模块,用于响应于接收到基于所述算子编辑区对至少两个目标数据处理算子 的用户操作,根据所述用户操作对各个所述目标数据处理算子进行编辑,得到各个所述目 标数据处理算子的执行顺序和执行参数,所述目标数据处理算子是所述n种数据处理算子 4 CN 111552470 A 说 明 书 2/16 页 中被选择的数据处理算子; 生成模块,用于根据各个所述目标数据处理算子的执行顺序和执行参数生成数据 分析任务。 可选的,所述算子编辑区包括算子组合区和参数编辑区,所述参数编辑区中提供 有算子参数设置控件。 可选的,所述编辑模块,包括: 第一获取子模块,用于在接收到基于所述算子组合区对各个所述目标数据处理算 子的顺序编排操作后,根据各个所述目标数据处理算子在所述算子组合区中的连接关系, 得到各个所述目标数据处理算子的执行顺序; 第二获取子模块,用于在接收到基于所述算子组合区对各个所述目标数据处理算 子的参数设置操作后,根据所述参数设置操作对各个所述目标数据处理算子进行参数设 置,得到所述各个所述目标数据处理算子的执行参数。 可选的,所述顺序编排操作包括选择操作、移动操作以及删除操作中的至少一种; 所述装置还包括: 增加模块,用于响应于接收到基于所述算子组合区对所述目标数据处理算子的选 择操作,根据所述选择操作在所述算子组合区中的所述数据分析任务中增加所述目标数据 处理算子; 移动模块,用于响应于接收到基于所述算子组合区对所述目标数据处理算子的移 动操作,根据所述移动操作在所述算子组合区中的所述数据分析任务中移动所述目标数据 处理算子的位置; 删除模块,用于响应于接收到基于所述算子组合区对所述目标数据处理算子的删 除操作,根据所述删除操作在所述算子组合区中的所述数据分析任务中删除所述目标数据 处理算子。 可选的,所述数据处理算子包括资产主数据算子、数据计算算子、数据质量算子以 及电量计算算子中的至少一种。 可选的,所述创建界面中还包括校验控件; 所述装置还包括: 校验模块,用于响应于接收到基于所述校验控件的校验操作,根据预先设置的数 据分析任务合法性校验规则对所述数据分析任务进行合法性校验; 其中,所述合法性校验包括对所述数据分析任务中各个数据处理算子的执行参数 进行合法性校验,以及,对所述数据分析任务中各个数据处理算子之间的组合搭配进行合 法性校验中的至少一种。 可选的,所述创建界面中还包括预览控件; 所述装置还包括: 第二接收模块,用于接收预览配置信息,所述预览配置信息用于验证所述数据分 析任务的输入数据和输出数据是否正常; 第二运行模块,用于响应于接收到基于所述预览控件的预览操作,基于所述预览 配置信息运行所述数据分析任务。 另一方面,提供了一种计算机设备,所述计算机设备包括处理器和存储器,所述存 5 CN 111552470 A 说 明 书 3/16 页 储器中存储有至少一条指令、至少一段程序、代码集或指令集,所述至少一条指令、所述至 少一段程序、所述代码集或指令集由所述处理器加载并执行以实现如上述方面所述的物联 网中的数据分析任务创建方法。 另一方面,提供了一种计算机可读存储介质,所述存储介质中存储有至少一条指 令、至少一段程序、代码集或指令集,所述至少一条指令、所述至少一段程序、所述代码集或 指令集由处理器加载并执行以实现如上述方面所述的物联网中的数据分析任务创建方法。 本申请提供的技术方案可以包括以下有益效果: 通过在可视化的数据分析任务的创建界面中,根据接收到的基于算子编辑区对至 少两个目标数据算子的用户操作,对各个目标数据处理算子进行编辑,得到各个目标数据 处理算子的执行逻辑和执行参数,根据各个目标数据处理算子的执行顺序和执行参数生成 数据分析任务,使得在数据分析任务开发过程中,将数据分析任务中的计算步骤算子化,并 利用可视化的创建界面进行数据分析任务的构建,提高了数据分析任务的开发效率。 应当理解的是,以上的一般描述和后文的细节描述仅是示例性和解释性的,并不 能限制本申请。 附图说明 此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本申请的实施 例,并与说明书一起用于解释本申请的原理。 图1示出了本申请一个示例性实施例提供的物联网中的数据分析任务创建方法的 流程图; 图2示出了本申请一个示例性实施例提供的物联网中的数据分析任务创建方法的 流程图; 图3示出了本申请一示例性实施例示出的数据分析任务的创建界面的示意图; 图4示出了本申请一示例性实施例示出的在数据分析任务中增加目标数据处理算 子的示意图; 图5示出了本申请一示例性实施例示出的在数据分析任务中增加目标数据处理算 子的示意图; 图6示出了本申请一示例性实施例示出的对目标数据处理算子进行移动的示意 图; 图7示出了本申请一示例性实施例示出的对目标数据处理算子进行移动的示意 图; 图8示出了本申请一示例性实施例提供的物联网中的数据分析任务创建方法的示 意图; 图9示出了本申请一示例性实施例提供的物联网中的数据分析任务创建装置的方 框图; 图10是根据一示例性实施例示出的计算机设备的结构框图; 图11是根据一示例性实施例示出的计算机设备的结构框图。 6 CN 111552470 A 说 明 书 4/16 页