免费 Databricks（Databricks-Certified-Professional-Data-Engineer）认证样题与在线练习测试 [Q94-Q114]

问题 94
要求您在 databricks 作业中设置两个任务，第一个任务运行笔记本电脑从远程系统下载数据，第二个任务是可以处理这些数据的 DLT 管道，您打算如何在作业用户界面中进行配置？

问题 95
以下哪项描述了 Databricks Repos 如何帮助促进 Databricks Lakehouse 平台上的 CI/CD 工作流？

问题 96
一个数据工程团队正在转换其现有的数据管道，以便利用自动加载器进行以下操作
在摄取 JSON 文件时进行增量处理。一位数据工程师遇到了以下代码
块：
1. （streaming_df = spark.readStream.format("cloudFiles")
.option("cloudFiles.format", "json")
.option("cloudFiles.schemaLocation", schemaLocation)
.load(sourcePath))
假定模式定位和源路径已正确设置，以下哪项更改会导致模式定位和源路径的改变？
数据工程师是否需要转换代码块，以便使用自动加载器来获取数据？

问题 97
数据分析师团队根据订单和补货情况创建了一些查询，用于识别缺货的项目，但当这些查询一起运行进行最终输出时，团队发现需要花费很长的时间，因此要求您研究查询运行缓慢的原因，并确定提高性能的步骤。可以采取以下哪些步骤来解决问题？
下面是查询示例
1.- 获取订单摘要
2.创建或替换表 orders_summary
3.as
4.select product_id, sum(order_count) order_count
5.from
6. (
7. 从 orders_instore 中选择 product_id、order_count
所有工会
9. 从在线订单中选择 product_id、order_count
10. )
11.按产品编号分组
12.- 获取供应摘要
13.创建或更新供应汇总表
14.as
15.select product_id, sum(supply_count) supply_count
16. 从供应
17.按产品编号分组
18.
19.- 根据订单摘要和供应摘要获得手头数据
20.
21.with stock_cte
22.as (
23.select nvl(s.product_id,o.product_id) as product_id、
nvl(supply_count,0) - nvl(order_count,0) 为 on_hand
25.from supply_summary s
26.Full outer join orders_summary o
27. on s.product_id = o.product_id
28.)
29.select *
30.from
31.stock_cte
32.where on_hand = 0

问题 98
您想构建一个 spark 流进程，以便每隔一段时间从 Kafka 队列读取数据并写入 Delta 表。
15 分钟，什么是正确的触发选项

问题 99
某公司新来了一名数据工程师。该数据工程师最近加入了公司的
Databricks 工作区为 [email protected]。数据工程师需要能够查询表
数据库零售销售。新数据工程师已被授予数据库零售的使用权。
以下哪些命令可用于向新数据工程师授予适当权限？

问题 100
以下哪种工具提供数据访问控制、访问审计、数据沿袭和数据发现功能？

问题 101
Delta 实时表格管道包括使用 STREAMING LIVE TABLE 定义的两个数据集。
使用 LIVE TABLE 针对 Delta Lake 表源定义了三个数据集。表格配置为
使用触发流水线模式在开发模式下运行。
假定存在以前未处理的数据，且所有定义都有效，那么处理后的预期结果是什么？
点击 "开始 "更新管道？

问题 102
您注意到工作群集启动需要 6 到 8 分钟，这耽误了您按时完成工作，您可以采取哪些措施来缩短群集启动时间？

问题 103
一名初级数据工程师需要创建一个 Spark SQL 表 my_table，由 Spark 同时管理数据和数据表。
元数据。元数据和数据还应存储在 Databricks 文件系统（DBFS）中。
高级数据工程师应与初级数据工程师共享以下哪些命令，以便
完成这项任务？

问题 104
当你发出 SQL DDL 命令 CREATE TABLE sales（id int，单位 int）时，创建的表类型是什么？

问题 105
在数据和分析解决方案中，Lakehouse 如何取代对使用数据湖和数据仓库的依赖？

问题 106
如何检查现有模式在 Delta Lake 中的位置？

问题 107
如何创建 delta 实时表管道并使用 DLT UI 进行部署？

问题 108
您目前正在创建一个 spark 流进程，用于一次性微型批处理的读写，同时重写现有的目标表，请填写空格以成功完成下面的命令。
1.spark.table("source_table")
2...writeStream
3..option("____", "dbfs:/location/silver")
4..outputMode("____")
5...trigger(Once=____)
6..table("target_table")

问题 109
多跳架构中青铜层的作用是什么？

问题 110
数据工程团队一直使用 Databricks SQL 查询来监控 ELT 作业的性能。
ELT 作业是由特定数量的输入记录触发的，这些记录随时可以处理。Databricks SQL
查询返回作业最近一次运行后的分钟数。
如果 ELT 作业没有完成，以下哪种方法可以让数据工程团队得到通知？
在一小时内运行过？

问题 111
以下哪条命令可用于删除存储中的托管 delta 表和底层文件？

问题 112
在清单流程结束时，一个文件被上传到云对象存储中，您需要建立一个流程来摄取数据，以下哪种方法可用于摄取增量数据？
以下是自动加载程序加载数据的命令，请填写空格，以便成功执行以下代码。
1.spark.readStream
2..format("cloudfiles")
3..option(“_______”,”csv)
4..option("_______", 'dbfs:/location/checkpoint/')
5...load(data_source)
6...writeStream
7..option("_______",' dbfs:/location/checkpoint/')
8..option("_______", "true")
9...table(table_name))

问题 113
您正在利用 COPY INTO 命令将外部 CSV 文件加载到 delta 表中，但在第二次运行该命令后，没有将数据加载到表名中，这是为什么？
1.COPY INTO table_name
2.FROM "dbfs:/mnt/raw/*.csv
3.fileformat = csv

问题 114
多跳架构中银层的作用是什么？