Topic 1 Question #1
您正在构建一个机器学习模型来检测实时传感器数据中的异常情况。您将使用发布/订阅机制来处理传入的请求。您希望存储结果以进行分析和可视化。您应该如何配置管道?
答案: A
本题考察Google Cloud专业机器学习工程师认证中实时机器学习管道的服务选型能力,题目核心需求有三点,一是对接发布订阅机制实时处理传感器流数据,二是运行已构建的异常检测机器学习模型得到检测结果,三是存储结果支持后续分析与可视化。选项A的三个组件正好对应管道的三个核心环节,流处理层用数据流消费发布订阅消息做实时数据预处理,推理层用AI平台部署的异常检测模型完成实时推理,存储层用BigQuery存储推理结果,同时支持SQL分析与BI可视化,完全匹配所有需求。
各选项分析:
A. 数据流即Google Cloud Dataflow,是托管的无服务器流批一体处理服务,原生支持对接发布订阅服务消费实时消息,完成传感器数据的清洗、格式化等预处理工作,符合实时管道的第一层需求;AI平台即Google Cloud AI Platform,是托管的模型推理服务,可直接部署训练好的异常检测模型,接收预处理后的实时数据输出检测结果,符合第二层推理需求;BigQuery是托管云数据仓库,支持海量数据的低成本存储,原生支持SQL查询分析,可直接对接Looker Studio等可视化工具生成分析报表,完全满足第三层存储与分析可视化需求,因此该选项正确。
B. 数据处理是通用概念而非特定的托管流处理服务,无法直接对接发布订阅构建生产级实时管道;AutoML是低代码模型训练服务,本题中模型已经构建完成,无需使用AutoML训练,且AutoML不适合承担高并发实时推理的工作;云端Bigtable是分布式宽表数据库,适合低延迟高并发的随机读写场景,原生不支持复杂SQL分析,也很难直接对接BI工具做可视化,不符合结果存储的需求,因此该选项错误。
C. BigQuery是分析型数据仓库,不具备实时流数据消费与预处理的能力,无法作为管道第一层对接发布订阅处理实时传感器数据;AutoML的核心能力是模型训练,不适用于实时推理场景;云函数是轻量事件驱动计算服务,不具备数据存储与分析能力,无法满足结果存储分析的需求,因此该选项错误。
D. BigQuery无法作为管道第一层处理实时流数据;云存储是对象存储服务,虽然可以存储结果数据,但原生不支持SQL查询分析,对接可视化工具的复杂度远高于BigQuery,不符合分析可视化的需求,因此该选项错误。
关键知识点:
1. 实时机器学习管道架构设计,核心要点是实时流数据处理、模型推理、结果存储三层需分别选择适配对应场景的云服务,满足低延迟、高可用、易分析的要求。
2. Google Cloud数据与AI服务场景适配,核心要点是Dataflow适用于流批数据预处理,AI Platform/Vertex AI适用于托管模型推理,BigQuery适用于分析型结果存储与即席查询。
3. 异常检测场景工程落地要求,核心要点是实时传感器异常检测场景需要流处理服务对接消息队列,推理服务支撑低延迟预测,数仓服务支撑后续的异常结果分析复盘。
参考资料:
构建实时异常检测管道, Google Cloud Professional Machine Learning Engineer 认证指南, https://cloud.google.com/certification/guides/machine-learning-engineer