摘要
本发明公开了一种基于大数据的工业互联网数据处理方法,包括设计可视化的数据处理流程编排工具,允许用户灵活定义数据处理的逻辑和步骤,在流程编排过程中,通过预定义的数据处理算子库,实现常见的数据处理操作;通过可视化配置界面,允许用户通过拖拉操作选择所需的数据处理组件,并设置相应的数据类型和处理条件,形成完整的数据处理流程图;获取用户配置的数据类型信息,根据这些信息对数据进行初次条件过滤判断,筛选出符合条件的原始数据;根据是否变化条件,判断是否需要随时间动态计算数据;引入实时数据处理引擎,对数据进行实时采集、清洗、转换和分析;通过可视化界面、NLP交互、实时处理和智能调度,提高了数据处理的灵活性。