一种智能设备实时数据流式处理方法及处理系统

摘要

本发明公开了一种智能设备实时数据流式处理方法，包括：步骤1，用户通过前端模块上传数据流处理程序包并配置需要启动的元数据信息；不同智能设备上传的实时数据流经过路由模块传输给对应的数据流处理程序实例进行处理；每个机器上部署的执行模块收集本机上所有的数据流处理程序实例信息，汇报给策略调度模块，策略调度模块根据这些信息来决定实例的扩缩容；日志收集模块收集机器上所有数据流处理程序实例的日志并提供一个日志查询接口，前端模块通过这个日志查询接口展示实例的日志。本发明还提供了一种智能设备实时数据流式处理系统。本发明的有益效果：有很强的鲁棒性，能够解决海量设备实时数据的处理问题。