基于湖仓一体的无人售卖机数据存储分析方法及装置

本发明公开一种基于湖仓一体的无人售卖机数据存储分析方法及装置，该方法通过MQTT或HTTP协议采集无人售卖机的传感器、设备数据，传感器；通过Apache Paimon管理传感器、设备数据的元数据和版本，并支持ACID事务及进行数据分层管理；利用Flink+Kafka对传感器、设备数据进行实时计算，实现库存监控、故障检测、动态定价；并利用Spark+Paimon对传感器、设备数据进行批量计算，完成用户行为分析、商品偏好预测、设备运行评估；通过可视化工具展示传感器、设备数据的分析结果，并提供实时仪表盘、运营支持和数据分析报告，辅助无人售卖机的运营决策。本发明实现多源数据高效整合与分析，降低运营成本，提升运营效率和用户体验。