[2024-07-10更新,88問] 無料Databricks Databricks-Certified-Professional-Data-Engineer試験問題集、Databricks-Certified-Professional-Data-Engineer受験記(ページ 18)

Databricks-Certified-Professional-Data-Engineer 試験問題 81

次の Python ステートメントのうち、クエリ内のスキーマ名とテーブル名を置換するために使用できるものはどれですか?

A. 1.table_name = "売上"
2.schema_name = "ブロンズ"
3.query = f"select * from schema_name.table_name"

B. 1.table_name = "売上"
2.query = "select * from {schema_name}.{table_name}"

C. 1.table_name = "売上"
2.query = f"select * from {schema_name}.{table_name}"

D. 1.table_name = "売上"
2.query = f"select * from + スキーマ名 +"."+テーブル名"

Databricks-Certified-Professional-Data-Engineer 試験問題 82

次の自動ローダー構造化ストリーミングコマンドのうち、ランディングエリアからブロンズへのホップを正常に実行できるものはどれですか?

A. 1.spark\
2..readStream\
3..format("csv")\
4..option("cloudFiles.schemaLocation",checkpoint_directory)\
5..load("着陸")\
6..writeStream.option("チェックポイントの場所", チェックポイントディレクトリ)\
7..テーブル(生)

B. 1.spark\
2..readStream\
3..format("cloudFiles")\
4..option("cloudFiles.format","csv")\
5..option("cloudFiles.schemaLocation",checkpoint_directory)\
6..load("着陸")\
7..writeStream.option("チェックポイントの場所", チェックポイントディレクトリ)\
8..テーブル(生)
（正しい）

C. 1.spark\
2..読む\
3..format("cloudFiles")\
4..option("cloudFiles.format","csv")\
5..option("cloudFiles.schemaLocation",checkpoint_directory)\
6..load("着陸")\
7..writeStream.option("チェックポイントの場所", チェックポイントディレクトリ)\
8..テーブル(生)

D. 1.spark\
2..readStream\
3..load(rawSalesLocation)\
4..writeStream \
5..option("チェックポイントの場所", チェックポイントパス).outputMode("追加")\
6..table("uncleanedSales")

E. 1.spark\
2..読む\
3..load(rawSalesLocation) \
4..writeStream\
5..option("チェックポイントの場所", チェックポイントパス) \
6..outputMode("追加")\
7..table("uncleanedSales")

Databricks-Certified-Professional-Data-Engineer 試験問題 83

夜間ジョブは、次のコードを使用してデータを Delta Lake テーブルに取り込みます。

パイプラインの次のステップでは、パイプラインの次のテーブルにまだ処理されていない新しいレコードを操作するために使用できるオブジェクトを返す関数が必要です。
この関数定義を完成させるコードスニペットはどれですか?
def new_records():

A. spark.readStream.table("bronze") を返します

B. spark.readStream.load("bronze") を返す

D. spark.read.option("readChangeFeed", "true").table ("bronze") を返します

Databricks-Certified-Professional-Data-Engineer 試験問題 84

以下のトランザクションデータを保存するために、既存の差分テーブルを作成するか上書きするように求められました。

A. 1.CREATE OR REPLACE DELTA TABLE トランザクション (
2.transactionId int、
3.transactionDate タイムスタンプ、
4.販売単位)

B. 1.トランザクションが存在する場合、テーブルを作成または置換します (
2.transactionId int、
3.transactionDate タイムスタンプ、
4.販売単位)
5.フォーマットデルタ

C. 1.CREATE IF EXSITS REPLACE TABLE トランザクション (
2.transactionId int、
3.transactionDate タイムスタンプ、
4.販売単位)

D. 1.CREATE OR REPLACE TABLE トランザクション (
2.transactionId int、
3.transactionDate タイムスタンプ、
4.販売単位)

Databricks-Certified-Professional-Data-Engineer 試験問題 85

実行中のすべてのストリームを停止する Python コードを記述するように求められました。次のコマンドのどれを使用すると、現在実行中のすべてのアクティブなストリームのリストを取得して、空白を埋めることができます。
1._____________ の場合:
2. s.stop()

A. spark.streams.getActive

B. getActiveStreams()

C. activeStreams()

D. spark.streams.active

E. Spark.getActiveStreams()

他のバージョン: 901Databricks.Databricks-Certified-Professional-Data-Engineer.v2024-09-16.q115; 900Databricks.Databricks-Certified-Professional-Data-Engineer.v2023-11-18.q93

最新アップロード: 159CrowdStrike.CCCS-203b.v2026-06-16.q114; 128WGU.Operations-Management.v2026-06-16.q23; 169EC-COUNCIL.312-49v11.v2026-06-16.q204; 180Microsoft.PL-300.v2026-06-16.q439; 142Fortinet.FCSS_LED_AR-7.6.v2026-06-16.q43; 172CheckPoint.156-215.82.v2026-06-15.q106; 124Salesforce.AP-215.v2026-06-15.q22; 138Nutanix.NCP-MCI-6.10.v2026-06-15.q88; 168CompTIA.CV0-004.v2026-06-15.q237; 183Microsoft.MS-102.v2026-06-15.q316

Databricks-Certified-Professional-Data-Engineer 試験問題 81

Databricks-Certified-Professional-Data-Engineer 試験問題 82

Databricks-Certified-Professional-Data-Engineer 試験問題 83

Databricks-Certified-Professional-Data-Engineer 試験問題 84

Databricks-Certified-Professional-Data-Engineer 試験問題 85

PDFファイルをダウンロード