2026年阿里云ACP大数据工程师认证考试真题题库

2026年阿里云ACP大数据工程师认证考试真题题库一、选择题（每题2分，共50分）1.关于阿里云大数据产品体系，以下描述错误的是？A.实时计算Flink版主要用于流式数据处理。B.数据工场DataWorks是一个可视化数据开发与治理平台。C.大数据计算服务MaxCompute主要用于处理离线数据，不支持实时分析。D.实时数仓Hologres支持高并发实时写入与查询。答案与解析：C。MaxCompute虽然主要面向离线大数据处理，但也支持准实时数据分析，例如通过增量数据处理或与实时计算产品结合。因此，“不支持实时分析”的说法过于绝对，是错误的。2.在DataWorks中，一个业务流程通常包含多个节点。关于节点依赖，以下说法正确的是？A.父节点运行成功后，所有子节点会同时开始运行。B.节点依赖只能通过“本节点”的输出作为“下游节点”的输入来配置。C.跨周期依赖是指上游节点本周期的实例运行成功后，下游节点本周期的实例才能开始运行。D.可以设置依赖上一周期（如昨天）的某个节点运行成功，再运行本节点。答案与解析：D。跨周期依赖是DataWorks调度的重要功能，允许节点依赖于上游节点上一周期或更早周期的实例状态。A错误，子节点需满足各自的上游依赖条件才会触发；B错误，依赖关系可以手动配置，不限于数据传递；C描述的是同周期依赖，而非跨周期依赖。3.将MaxCompute表中的数据同步至AnalyticDBforPostgreSQL时，发现同步任务失败，报错信息提示“目标表字段长度不足”。最可能的原因是？A.MaxCompute项目空间与AnalyticDB实例的网络不通。B.同步任务配置的并发数过高。C.MaxCompute源表中存在某些字符串字段的实际数据长度超过了AnalyticDB目标表对应字段的定义长度。D.使用的数据同步工具版本过低。答案与解析：C。这是数据同步中常见的数据类型或长度不匹配问题。当源端数据值不符合目标端表的约束（如字段长度、精度、非空约束等）时，会导致写入失败。A会导致连接失败而非字段错误；B和D可能导致性能或兼容性问题，但报错信息通常不直接指向字段长度。4.使用实时计算Flink版处理一个用户点击流日志时，需要统计每个广告位最近5分钟的点击量。最合适的窗口类型是？A.滚动窗口（TumblingWindow）B.滑动窗口（SlidingWindow）C.会话窗口（SessionWindow）D.全局窗口（GlobalWindow）答案与解析：B。滑动窗口可以定义窗口大小和滑动步长。统计“最近5分钟”这种固定时间区间、且数据会不断更新的指标，通常使用滑动窗口，并将窗口大小设为5分钟，滑动步长设为较小的值（如1秒），以实现近似实时的滚动统计。A的窗口不重叠，适合周期性统计；C基于事件间隔，适合用户行为会话；D无界，需自定义触发器。5.在DataWorks中配置MaxComputeSQL节点时，为了安全且方便地引用一个不固定的日期（如业务日期），通常使用什么方式？A.在代码中直接写入系统函数，如`CURRENT_DATE()`。B.使用调度参数，如`${bizdate}`，并在运行时由系统替换。C.在每次运行前手动修改SQL代码中的日期值。D.通过一个额外的Shell节点动态生成日期并写入环境变量。答案与解析：B。调度参数是DataWorks调度系统的核心功能之一。`${bizdate}`等参数会根据调度配置的周期（如天调度）自动替换为具体的业务日期（通常是运行日期的前一天），从而实现代码与具体运行时间的解耦，保证任务调度的灵活性和准确性。6.关于阿里云对象存储OSS与大数据计算服务的结合，以下做法不推荐的是？A.将原始日志文件存储在OSS，通过外部表映射供MaxCompute直接查询分析。B.将MaxCompute的计算结果表直接输出到OSS，供下游系统下载。C.将需要频繁进行复杂关联分析的数百TB历史数据存储在OSS，通过外部表进行分析以节省MaxCompute存储成本。D.将实时计算Flink版处理后的维度更新数据写入OSS，供其他系统读取。答案与解析：C。虽然OSS成本低于MaxCompute内部存储，但对于需要频繁进行复杂关联分析的数百TB数据，使用外部表性能会远低于MaxCompute内部表。内部表针对列存储和计算优化，而外部表查询涉及OSS数据读取和网络传输，延迟高、吞吐有限。对于热数据或复杂分析，应优先考虑存储在MaxCompute内部。A、B、D均是合理的冷热数据分层或数据交换场景。7.Hologres中，为了实现对一张十亿行级别表的主键（PrimaryKey）查询达到毫秒级响应，建表时最关键的是？A.设置合适的分布键（DistributionKey），将数据打散到各个Shard。B.在查询条件列上创建位图索引（BitmapIndex）。C.设置合适的聚集索引（ClusteringKey），使数据按主键物理有序存储。D.设置合适的表分区（PartitionKey），按时间范围裁剪数据。答案与解析：C。Hologres是行列混合存储，其聚集索引（ClusteringKey）决定了数据在文件内的物理排序顺序。将主键设置为聚集索引，可以使基于主键的点查直接定位到具体文件块，极大减少IO，实现毫秒级响应。A影响数据分布，对全局查询性能重要，但对点查提升有限；B的位图索引适用于低基数列的过滤；D用于数据生命周期管理和范围查询加速。8.使用DataWorks数据集成同步数据时，若源端为MySQL，目标端为MaxCompute，发现同步速度远低于预期。以下哪项措施通常不能有效提升同步速度？A.在数据集成任务配置中调大“并发数”。B.对MySQL源表根据主键进行分段（Split），实现并发读取。C.将MySQL源表中的数据先导出为文本文件，再上传至MaxCompute。D.检查并确保源库与数据集成运行资源组之间的网络带宽和延迟符合要求。答案与解析：C。将数据先导出为文件再上传，增加了额外的步骤和I/O开销，流程复杂且通常不会比优化后的直连同步更快。A和B是通过提高并发度来加速读取；D是排除网络瓶颈，都是提升同步速度的有效手段。9.在实时计算Flink版中，使用`GROUPBY`和`TUMBLE`窗口进行聚合时，出现了“数据倾斜”，导致某个Subtask处理的数据量远大于其他Subtask。以下哪种方法最可能缓解此问题？A.增大作业的总并行度。B.在`GROUPBY`的Key上添加随机后缀，进行两阶段聚合。C.使用`FILTER`语句过滤掉部分数据。D.调大TaskManager的堆内存。答案与解析：B。这是处理Keyed数据倾斜的经典方法。先对原始Key加盐（如拼接随机数），进行一次预聚合，分散负载；然后再对原始Key进行二次聚合，得到最终结果。A可能使倾斜的Key仍然集中到少数几个Subtask，无法根治；C改变了业务逻辑；D只是提供更多资源，无法解决分配不均问题。10.关于MaxCompute的安全体系，以下说法正确的是？A.项目空间（Project）管理员可以无条件访问该项目内所有对象和数据。B.表（Table）的创建者（Owner）自动拥有该表的读、写、删权限，且权限不可撤销。C.可以通过标签（Label）安全机制，实现基于数据敏感级别的行级或列级访问控制。D.用户被移除出项目空间后，其之前授权的ACL策略会自动保留。答案与解析：C。MaxCompute的LabelSecurity是一种强制访问控制模型，管理员可以为表、列或行设置敏感度标签，为用户设置安全等级，系统自动控制用户能否访问相应数据。A错误，管理员权限也受ACL和Policy限制；B错误，Owner权限可以通过ACL被项目管理员修改或撤销；D错误，用户离开项目后，其相关ACL授权会被清理。11.为MaxCompute中的一个大型事实表（FactTable）添加一个非分区列，并更新该列的数据。以下哪种方式对线上查询影响最小？A.使用`INSERTOVERWRITETABLE`重写整张表。B.创建一张新表（包含新列），将数据从旧表插入新表，然后重命名替换。C.使用`ALTERTABLEADDCOLUMN`添加列，然后用多个`UPDATE`语句分批更新数据。D.使用`ALTERTABLEADDCOLUMN`添加列，然后使用`INSERTOVERWRITE`指定分区重写有数据变动的分区。答案与解析：D。MaxCompute主要面向分区表。`ALTERTABLEADDCOLUMN`是元数据操作，瞬间完成。如果新增列的数据更新只涉及部分分区，使用`INSERTOVERWRITE`重写相关分区，可以最小化数据重写量和计算资源消耗，对未更新分区的查询无影响。A和B会重写全表数据，影响大且成本高；C的`UPDATE`语句在MaxCompute中效率较低，不适合大批量更新，且可能产生大量小文件。12.在DataWorks中，一个周期性调度的任务实例失败后，系统不会自动执行以下哪项操作？A.根据任务配置的“重跑”属性，自动重试该实例。B.触发配置的该任务下游依赖实例的状态变为“未运行”。C.自动向任务负责人发送报警通知（如果已配置）。D.自动分析失败原因并修复代码。答案与解析：D。DataWorks的运维中心提供实例监控、重跑、告警等功能，但不会自动修复用户代码逻辑错误。A、B、C都是系统在任务失败后可提供的自动化运维行为。13.使用Flink处理有序事件流时，为了容忍一定程度的乱序事件并保证窗口计算的正确性，最应该设置哪个参数？A.并行度（Parallelism）B.水位线延迟（WatermarkDelay）C.检查点间隔（CheckpointInterval）D.状态存活时间（TTL）答案与解析：B。水位线（Watermark）是衡量事件时间进展的机制。设置水位线延迟（允许乱序的时间间隔），意味着系统会等待一段时间，以期望延迟到达的事件能够被纳入正确的窗口计算，然后再触发窗口计算，这是处理乱序数据的核心方法。14.将Hologres作为维度表与Flink流计算进行维表关联时，若维度表数据更新不频繁但要求关联查询低延迟，推荐使用哪种缓存策略？A.不缓存（None）B.最近最少使用缓存（LRU）C.全量缓存（All）D.异步查询答案与解析：C。对于更新不频繁的小型维度表，使用全量缓存策略可以将整个维度表加载到Flink任务节点的内存中。后续的流数据关联查询直接在内存中进行，延迟极低，且避免了对外部数据库（Hologres）的频繁查询压力。15.在MaxCompute中，对一张分区表执行`SELECT`查询时，在`WHERE`条件中指定了分区列的范围，这将会？A.减少从磁盘读取的数据量，因为分区裁剪（PartitionPruning）会生效。B.减少参与计算的数据量，因为数据在计算前会先进行过滤。C.增加SQL解析的时间。D.保证结果一定按分区列排序。答案与解析：A。分区裁剪是MaxCompute的重要优化特性。当查询条件包含分区列的过滤时，优化器会识别出需要扫描的分区范围，直接跳过不满足条件的分区目录和数据文件，从而显著减少I/O和数据读取量。B描述的是行级过滤，发生在数据读取之后；C和D与分区裁剪无直接关系。16.DataWorks数据质量（DQC）规则中，“表行数波动检测”属于哪种监控类型？A.强规则监控B.弱规则监控C.自定义SQL监控D.动态阈值监控答案与解析：B。弱规则监控通常用于监控数据指标的波动情况，如表行数、主键唯一数、空值率等相对于历史同期（如昨天、上周同天）的波动比例是否在合理范围内。强规则监控是绝对阈值判断（如>，<，=）；C是通过自定义SQL返回结果判断；D是阈值可动态调整的监控。17.关于阿里云Elasticsearch与大数据生态的集成，以下场景不合适的是？A.将MaxCompute中清洗后的用户画像标签结果同步至Elasticsearch，提供用户标签检索服务。B.将Flink处理后的实时订单日志写入Elasticsearch，用于实时订单状态查询与仪表盘展示。C.将数百TB的历史交易明细数据导入Elasticsearch，用于复杂的多表关联分析与批量报表生成。D.将网站点击流日志通过Logstash采集到Elasticsearch，进行日志分析和错误排查。答案与解析：C。Elasticsearch擅长全文检索、日志分析和基于倒排索引的快速过滤与聚合，但其存储成本相对较高，且不适合处理需要复杂关联（如多表Join）和大量数据扫描（数百TB）的批量分析场景。这类场景更适合使用MaxCompute或AnalyticDB等OLAP引擎。A、B、D都是Elasticsearch的典型应用场景。18.使用MaxCompute的UDF（用户自定义函数）时，关于资源（Resource）的说法正确的是？A.UDF的JAR包资源必须上传至项目空间，函数才能创建成功。B.一个UDF只能关联一个资源文件。C.更新UDF代码时，必须先删除旧函数，再基于新资源创建新函数。D.资源文件上传后，其内容可以被项目内所有用户直接查看和下载。答案与解析：A。在MaxCompute中创建UDF（尤其是JavaUDF），需要先将包含函数逻辑的JAR包作为资源（Resource）上传到项目空间，然后在创建函数时引用该资源。B错误，一个UDF可以依赖多个资源文件；C错误，可以通过`ALTERFUNCTION`更新函数引用的资源；D错误，资源文件内容不可直接查看，下载也需要相应权限。19.在DataWorks数据地图中，可以通过以下哪种方式快速查找数据表？A.仅支持按表名精确搜索。B.可以按表名、字段名、表注释、项目名称等进行模糊搜索。C.只能通过目录树逐级浏览。D.必须知道表的唯一ID才能查找。答案与解析：B。数据地图提供强大的元数据搜索能力，支持对表名、字段名、注释、负责人、项目名等多种元信息进行关键词的模糊搜索，是数据发现和血缘追溯的重要工具。20.为保障MaxCompute生产项目的稳定性，以下哪项是最佳实践？A.将所有开发、测试、生产任务都在同一个MaxCompute项目中运行。B.为生产项目购买足够的CU（计算单元）资源，并设置项目级CU上限。C.允许所有项目成员拥有`CreateInstance`权限，以便灵活执行任务。D.关闭项目的数据保护（DataProtection）功能，避免误操作被拦截。答案与解析：B。为生产项目设置合理的CU资源并配置上限，可以防止异常任务或突发高负载消耗所有资源，影响核心作业的稳定性，这是成本与稳定性控制的关键。A违反环境隔离原则；C权限过大，存在安全风险；D关闭保护会增加误删数据等操作的风险。21.使用FlinkCEP（复杂事件处理）检测用户连续三次登录失败的场景，以下描述错误的是？A.需要定义一个模式（Pattern）来序列“登录失败”事件。B.可以设置时间约束，如10分钟内连续失败三次。C.处理乱序事件时，使用事件时间（EventTime）语义比处理时间（ProcessingTime）语义更准确。D.CEP处理后的输出流，其时间戳一定与最后一个匹配事件的时间戳相同。答案与解析：D。CEP输出的复杂事件（如超时、匹配成功）会生成新的时间戳，这个时间戳取决于匹配完成的时间（例如，模式匹配结束时），并不一定等于最后一个匹配事件的时间戳。A、B、C是CEP应用中的正确概念。22.在Hologres中，若一个查询既包含对分布键（DistributionKey）的等值过滤，又包含对聚集索引（ClusteringKey）的范围查询，该查询会如何执行？A.仅触发分布键过滤，数据被定位到单个Shard。B.仅触发聚集索引过滤，在所有Shard上扫描有序数据。C.先通过分布键过滤定位到特定Shard，再在该Shard上利用聚集索引进行高效范围扫描。D.无法同时利用两种索引，会进行全表扫描。答案与解析：C。这是Hologres的优化执行路径。分布键的等值过滤可以将查询路由到存储该数据的一个或少数几个Shard上（理想情况是单个Shard），大大减少参与查询的节点数。然后，在该Shard内部，由于数据按聚集索引排序，可以高效地进行范围扫描。这种组合能实现极低的查询延迟。23.关于DataWorks的“独享数据集成资源组”，以下说法错误的是？A.可以部署在用户自己的VPC内，实现与云上数据库的网络互通。B.相比默认的共享资源组，性能更稳定，任务隔离性更好。C.必须与DataWorks工作空间所在区域相同。D.其规格（CPU/内存）不可调整。答案与解析：D。独享数据集成资源组可以根据业务负载进行弹性扩缩容，调整其规格（如升级CPU和内存），以满足不同阶段的数据同步性能需求。A、B、C都是其正确特点。24.在MaxCompute中执行一个多表Join的复杂查询，长时间没有返回结果。通过LogView查看，发现某个FuxiTask的Instance长时间处于Running状态，最可能的原因是？A.该Instance所在的计算节点发生了硬件故障。B.发生了数据倾斜，该Instance需要处理的数据量远大于其他Instance。C.SQL语法存在错误，导致解析失败。D.项目空间的CU资源已耗尽。答案与解析：B。在MaxCompute执行中，LogView是重要的诊断工具。某个或某几个Instance长时间运行，而其他Instance早已完成，是典型的数据倾斜现象。倾斜的Key导致大量数据被分配到了少数几个处理单元。A会导致节点失联，任务失败而非卡住；C在提交阶段就会报错；D会导致任务无法启动或排队。25.使用阿里云DTS（数据传输服务）将自建IDC的Oracle数据库增量数据实时同步到阿里云大数据体系，希望最终能用于实时和离线分析。以下架构设计最合理的是？A.DTS->RDSMySQL->DataWorks数据集成->MaxComputeB.DTS->数据总线DataHub->实时计算Flink版/MaxComputeC.DTS->OSS->MaxCompute外部表D.DTS->日志服务SLS->Elasticsearch答案与解析：B。DataHub是阿里云流式数据总线，可以作为实时数据汇聚层。DTS将Oracle的增量数据（如CDC）实时写入DataHub，然后一条链路供Flink消费进行实时计算，另一条链路可以通过Flink或DataWorks定期/实时地写入MaxCompute供离线分析。这实现了实时与离线数据同源。A路径长，实时性差；C不适合实时增量；D只满足了搜索/日志分析场景。二、多项选择题（每题3分，共15分，全部选对得满分，少选得部分分，错选不得分）26.以下哪些是MaxCompute适合处理的场景？（）A.对海量历史交易数据进行月度汇总报表计算。B.对网站实时点击流进行毫秒级异常检测。C.存储和查询万亿级别的用户行为日志，用于数据挖掘。D.为在线商城提供高并发（每秒数万次）的商品库存查询。E.对数百TB的科研数据进行基因序列比对分析。答案与解析：A、C、E。MaxCompute是面向海量数据（PB级别）的离线计算和存储平台，擅长批量计算、数据仓库、数据挖掘和科学计算。B是典型的流式计算和实时处理场景，适合Flink；D是高并发低延迟的在线查询场景，适合Hologres、RDS或Tair。27.在DataWorks中，可以通过哪些方式保障数据开发流程的规范与质量？（）A.使用标准函数和模板，进行代码规范检查。B.为生产任务配置基线监控和保障，确保重要任务按时完成。C.在数据集成任务中，对源端和目标端进行数据一致性对比。D.通过数据地图为表添加业务标签和术语，方便理解。E.使用数据服务（DataAPI）将数据表快速封装成API供应用调用。答案与解析：A、B、C、D。A涉及代码规范；B涉及任务调度保障；C涉及数据质量校验；D涉及数据治理和知识沉淀。这些都是保障数据开发流程规范与质量的手段。E是数据服务化能力，虽然重要，但不直接属于开发流程规范与质量保障的范畴。28.实时计算Flink版中，状态（State）的管理至关重要。以下哪些操作会访问或更新状态？（）A.在KeyedStream上使用`map`函数，其中访问了一个通过`ValueState`定义的变量。B.使用`WindowedStream`的`apply`或`process`函数进行窗口计算。C.在DataStream上使用`filter`函数过滤数据。D.使用`Connect`操作符连接两个流，并在`CoProcessFunction`中访问`ListState`。E.使用`KeyedStream`的`intervalJoin`操作。答案与解析：A、B、D、E。A中的`ValueState`是KeyedState；B窗口计算通常涉及聚合状态；D中的`CoProcessFunction`可以访问连接流的状态；E间隔连接（IntervalJoin）需要存储一段时间内的事件状态用于匹配。C是简单的无状态转换。29.关于Hologres的实时数据导入，以下哪些方式支持高吞吐、低延迟的写入？（）A.通过JDBC使用单条`INSERT`语句逐行插入。B.通过JDBC使用批量`INSERT`（BatchInsert）或COPY命令。C.通过DataWorks数据集成任务进行同步。D.通过FlinkConnector写入。E.通过开源PostgreSQL的`pg_dump`工具导入。答案与解析：B、C、D。B（批量操作）能减少网络往返和事务开销；C（数据集成）针对大数据量同步优化；D（FlinkConnector）是流式写入的推荐方式，支持高吞吐。A逐条插入性能极差；E`pg_dump`用于逻辑备份恢复，不适合实时导入。30.在MaxCompute中，以下哪些操作会产生额外的存储费用？（）A.创建一张内部表（无论是否有数据）。B.向分区表的一个已有分区插入数据，使得该分区数据量增加。C.删除一张内部表。D.为表添加一个注释（Comment）。E.将表的数据生命周期（Lifecycle）从7天修改为30天，表中已有10天前的数据。答案与解析：B、E。MaxCompute的存储费用按数据占用的实际存储量计费。B增加数据量，费用增加。E延长生命周期，原本在第8天会被删除的数据将继续保留，导致存储量增加，可能产生更多费用。A创建空表不占存储空间；C删除表释放空间，减少费用；D修改注释是元数据操作，不影响存储。三、判断题（每题1分，共10分）31.DataWorks的“数据开发”模块与“运维中心”模块是独立的，开发好的节点必须手动提交到运维中心才能被调度执行。（）答案与解析：错误。在DataWorks中，开发好的节点需要发布到生产环境（运维中心），但发布操作通常是在开发界面完成工作流提交后，通过“发布”流程将任务包部署至运维中心，并非完全独立的手动操作。调度配置在开发时设定，发布后生效。32.MaxComputeSQL支持标准的ACID事务，可以对单条记录进行读-修改-写回的操作。（）答案与解析：错误。MaxCompute主要面向大规模批量数据处理，不支持行级的事务（如单条记录的UPDATE、DELETE）。其数据操作（如INSERTOVERWRITE）在作业级别具有原子性，但非传统OLTP数据库的细粒度ACID事务。33.实时计算Flink版的检查点（Checkpoint）功能，主要用于保存计算逻辑的JAR包，以便失败时重启。（）答案与解析：错误。检查点（Checkpoint）的核心作用是定期将算子的状态（State）持久化到可靠的存储（如OSS），用于故障恢复时从最近的一致状态重启，保证Exactly-Once语义。它不保存JAR包，JAR包在作业提交时已上传。34.Hologres兼容PostgreSQL生态，因此所有为PostgreSQL编写的第三方工具和驱动都可以不经修改直接用于Hologres。（）答案与解析：错误。Hologres高度兼容PostgreSQL协议和语法，但由于其是面向实时分析的架构，存在一些特定功能、扩展或系统函数的差异。并非所有PostgreSQL工具和驱动都能100%兼容，通常推荐使用官方验证过的驱动和工具。35.使用DataWorks数据集成同步数据时，如果源端是MySQL且无增量标识字段，则无法实现增量同步。（）答案与解析：错误。即使没有增量标识字段（如`update_time`），也可以通过其他方式实现增量同步，例如：使用数据集成的高级特性（如基于binlog日志的实时同步，但需MySQL开启binlog）、通过对比全量数据的校验和、或通过业务上可识别增量的其他逻辑（如自增主键范围）。但无标识字段时，方案的复杂度和性能开销会更高。36.MaxCompute的Lightning（闪电图）功能，可以对MaxCompute内部表进行亚秒级交互式查询。（）答案与解析：错误。MaxComputeLightning服务是对外部表（存储在OSS上的数据）提供快速交互式查询的服务。对于MaxCompute内部表，其快速查询通常通过Hologres或MCQA（MaxCompute快速查询加速）等方案实现。37.在Flink作业中，设置并行度（Parallelism）为1可以避免数据倾斜问题。（）答案与解析：正确，但无实际意义。当并行度为1时，所有数据都在同一个Subtask中处理，自然不存在不同Subtask间负载不均的“数据倾斜”问题。但这牺牲了并行处理能力，仅适用于数据量极小的场景，不是解决数据倾斜的推荐方法。38.DataWorks的数据服务（DataAPI）支持将MaxCompute、Hologres等多种数据源的表生成API，并自动进行流量控制和监控。（）答案与解析：正确。数据服务是DataWorks的一个模块，支持将多种数据源（包括但不限于MaxCompute、Hologres、RDS等）的数据表或自定义SQL查询，快速生成、发布和管理RESTfulAPI，并提供流量控制、监控报警等API管理功能。39.阿里云机器学习平台PAI可以直接读取MaxCompute表作为训练数据，并将训练好的模型部署为在线服务。（）答案与解析：正确。PAI与MaxCompute深度集成，支持将MaxCompute表作为数据源进行模型训练、评估。同时，PAI提供了模型在线服务（EAS）平台，可以将训练好的模型一键部署为高性能、高可用的RESTfulAPI服务。40.为MaxCompute项目配置IP白名单后，只有白名单内的IP地址可以访问该项目内的所有资源，项目成员身份认证不再需要。（）答案与解析：错误。MaxCompute的IP白名单是网络层访问控制，与用户身份认证是两道独立的安全防线。即使IP在白名单内，用户仍需通过AccessKey或云账号进行身份认证和权限校验，才能执行具体操作。四、简答题（每题5分，共15分）41.简述在DataWorks中，如何通过“参数节点”和“分支节点”实现一个有条件执行的工作流。答案与解析：首先，使用“参数节点”（如Shell节点）来执行一段逻辑，该逻辑根据业务规则或查询结果，输出一个决定后续流程走向的变量（例如，`condition=‘yes’`或`condition=‘no’`）。这个输出变量可以通过ODPS_OUTPUT参数等方式注册为工作流参数。然后，在工作流中配置一个“分支节点”。在分支节点的条件设置中，引用上一步参数节点输出的变量。例如，可以设置两个分支条件：`co最后，将不同的下游任务节点分别挂载到对应的分支出口上。这样，工作流运行时，会根据参数节点计算出的实际变量值，动态选择执行其中一个分支路径的下游任务，实现条件逻辑。42.列举三种MaxCompute中数据倾斜的常见场景及对应的优化思路。答案与解析：（1）Join倾斜：当一张小表与大表Join时，小表的某个Key数据量极大（如`join_key=NULL`或默认值大量集中）。优化思路：考虑过滤掉这个倾斜Key的数据单独处理；或者将小表膨胀，使用MapJoin并设置倾斜Key打散。优化思路：考虑过滤掉这个倾斜Key的数据单独处理；或者将小表膨胀，使用MapJoin并设置倾斜Key打散。（2）GroupBy倾斜：聚合的Key分布不均，某些Key对应的记录数远超其他。优化思路：采用两阶段聚合。先对原始Key加随机前缀进行局部聚合，再对原始Key进行全局聚合。优化思路：采用两阶段聚合。先对原始Key加随机前缀进行局部聚合，再对原始Key进行全局聚合。（3）动态分区倾斜：`INSERTOVERWRITE...PARTITION`时，写入某个或某几个分区的数据量特别大。优化思路：检查分区键的数据分布，尝试使用`DISTRIBUTEBY`将数据更均匀地分发到处理动态分区的Worker上；或者调整业务逻辑，避免产生极端分区。优化思路：检查分区键的数据分布，尝试使用`DISTRIBUTEBY`将数据更均匀地分发到处理动态分区的Worker上；或者调整业务逻辑，避免产生极端分区。43.在实时计算Flink版中，什么是“精确一次（Exactly-Once）”语义？结合Source、计算和Sink三个环节，简述实现端到端Exactly-Once通常需要的条件。答案与解析：“精确一次”语义是指：即使在发生故障时，每条数据对于整个流处理应用的影响也只会发生一次，不会丢失也不会重复。实现端到端Exactly-Once通常需要：Source端：支持数据重放（Replay）或提供消费位点（Offset）的提交与恢复机制。例如，Kafka可以作为可重放的Source。计算端：开启Flink的检查点（Checkpoint）机制。Checkpoint定期将算子状态和Source位点持久化到状态后端（如RocksDB）和持久化存储（如OSS）。故障恢复时，Source从持久化的位点重新消费，算子状态回滚到检查点状态。Sink端：需要支持幂等写入（如基于主键覆盖写）或参与两阶段提交（2PC）事务。例如，支持2PC的数据库（如某些JDBCSink）或支持幂等写入的消息队列/存储系统（如Hologres的Upsert）。这样能保证计算结果只被写入外部系统一次。五、综合应用题（10分）44.假设你是一家电商公司的数据工程师，需要设计一个实时数据仓库系统，以支持以下需求：（1）实时监控大屏：展示最近1小时的总销售额、订单数、热门商品Top10（要求数据延迟小于3秒）。（2）实时用户画像更新：用户每次浏览或购买行为后，其标签（如“高价值用户”、“偏好数码”）需