一种融合AI技术的云计算大数据实时处理方法及系统

本发明公开了一种融合AI技术的云计算大数据实时处理方法及系统，涉及大数据实时处理方法技术领域，包括采用数据接入接口从多个异构数据源采集原始数据，得到原始数据集；采用分布式计算框架对原始数据集进行预处理，并得到预处理后的数据集；基于机器学习算法和预处理后的数据集构建负载状态预测模型，输入预处理后的数据集，并输出负载状态预测结果；基于负载状态预测结果调整原始数据集中云计算资源分配量，得到资源分配策略；基于资源分配策略，采用流处理技术搭建数据处理通道，并结合AI算法执行识别任务，得到分析结果；基于分析结果生成特定应用场景的决策报告；通过配置Kafka Connect连接器与多个异构数据源进行连接，实现了多源数据的高效集成。