基于发布订阅式物联网大数据实时处理方法、装置及系统

摘要

本发明公开了一种基于发布订阅式物联网大数据实时处理方法、装置及系统，所述方法包括启动独立线程从数据库信息中获取业务应用数据，并同步到缓存中，形成缓存业务信息；响应于业务应用被操作的信号，获得变更信息，并基于发布订阅方式对所述缓存业务信息进行数据更新；对设备采集的数据进行预处理，获得结构化数据；对所述缓存业务信息和结构化数据进行数据关联，形成新的结构体；基于所述新的结构体，进行实时业务处理。本发明基于发布订阅的方式实现了数据库的更新与缓存信息的同步，既提高了流式计算与数据库数据交互的性能，又保证了数据准确性。