DP-700: Implementing Data Engineering Solutions Using Microsoft FabricDemo

You have an Azure SQL database named DB1.

In a Fabric workspace, you deploy an eventstream named EventStreamDB1 to stream record changes from DB1 to a lakehouse.

You discover that events are not being propagated to EventStreamDB1.

You need to ensure that events are propagated to EventStreamDB1.

What should you do?

You have a Fabric workspace containing a lakehouse named Lakehouse1.

An external data source contains data files that are 500 GB each, and a new file is added every day.

You need to ingest the data into Lakehouse1 without applying transformations. The solution must meet these requirements:

• Trigger the process when a new file is added.
• Provide the highest throughput.

Which type of item should you use to ingest the data?

You have an Azure subscription that contains a blob storage account named sa1. sa1 contains two files named File1.csv and File2.csv.

You have a Fabric tenant that contains the items shown in the following table.

You need to configure Pipeline1 to perform the following actions:

• At 2 PM each day, process File1.csv and load the file into flh1.

• At 5 PM each day, process File2.csv and load the file into flh1.

The solution must minimize development effort.

What should you use?

You have a Fabric workspace containing a warehouse named Warehouse1. Warehouse1 has a table named Customer, which contains the following data.

You have an internal Microsoft Entra user named User1 whose email address is [email protected].

You need to grant User1 access to the Customer table while preventing access to the CreditCard column.

How should you complete the statement?

GRANT Select… ON

Customers(CustomerID, FirstName, LastName, Phone)

TO Select…

You have a Fabric workspace that includes a semantic model called Model1.

You need to dynamically run and monitor Model1's refresh progress.

What should you use?

You have a Fabric workspace named Workspace1 that contains an Azure Data Factory pipeline named Pipeline1.

You need to monitor Pipeline1’s execution and activity status and automatically email an alert if the pipeline fails. The solution must minimize development and administrative effort.

What should you use to monitor Pipeline1, and what should you use to email the alert?

You have a Fabric workspace containing a warehouse named DW1. DW1 contains the following tables and columns.

You need to create output that shows summarized order quantities by year and product. The results must include an order-quantity summary at the year level across all products.

How should you complete the code?

Select…(SO.ModifiedDate) AS OrderDate
,P.Name AS ProductName
,SUM(SO.OrderQty) AS OrderQty

FROM [dbo].[SalesOrderDetail] SO

INNER JOIN [dbo].[Product] P

ON P.ProductID = SO.ProductID

GROUP BY
Select…

ORDER BY OrderDate

You have a Fabric workspace containing an eventstream named EventStream1. An EventStream1 transformation fails. You need to find the following error information:

You have a Fabric deployment pipeline that uses three workspaces named Dev, Test, and Prod.

You need to deploy an eventhouse as part of the deployment process.

What should you use to add the eventhouse to the deployment process?

You have a Fabric eventhouse containing a KQL database. The database includes a table named TaxiData. The following shows a sample of the data in TaxiData.

You need to create two KQL queries. The solution must satisfy these requirements:

• One query must partition RunningTotalAmount by VendorID.
• The other query must create a FirstPickupDateTime column that displays the first value of each hour from tpep_pickup_datetime, partitioned by payment_type.

How should each query be completed? Each value can be used once, multiple times, or not at all.

Statement1:
TaxiData
| sort by VendorID asc
| extend RunningTotalAmount = (total_amount, VendorID != prev(VendorID))

Statement2:
TaxiData
| sort by tpep_pickup_datetime asc, payment_type asc
| extend FirstPickupDateTime = (tpep_pickup_datetime, 1h, 0m, payment_type != prev(payment_type))

You have a Fabric workspace named Workspace1 that contains a lakehouse named Lakehouse1.

You perform the following actions:

• Connect Workspace1 to a Git repository and select the main branch.

• Create a new branch named feature1 and modify Lakehouse1.

• Merge the changes from feature1 into the main branch.

You need to ensure that the changes are available in Workspace1. The solution must minimize changes to Workspace1.

What should you do?

Your company’s sales department uses two Fabric workspaces, named Workspace1 and Workspace2.

The company decides to implement a domain strategy for organizing the workspaces.

You must ensure that a user can perform these tasks:

• Create a new domain for the sales department.
• Create two subdomains: one for the east region and one for the west region.
• Assign Workspace1 to the east-region subdomain.
• Assign Workspace2 to the west-region subdomain.

The solution must adhere to the principle of least privilege.

Which role should be assigned to the user?

You have a Fabric workspace that includes a lakehouse named Lakehouse1.

An external data source contains data files of 500 GB each. A new file is added each day.

You need to ingest the data into Lakehouse1 without applying transformations. The solution must meet the following requirements:

• Trigger the process when a new file is added.
• Provide the highest throughput.

Which type of item should you use to ingest the data?

A Fabric deployment pipeline uses three workspaces named Dev, Test, and Prod.

You need to deploy an Eventhouse as part of the deployment process.

What should you use to add the Eventhouse to that deployment process?

You have a Fabric workspace named Workspace1.

Your company obtains GitHub licenses.

You need to configure source control for Workpace1 to use GitHub. The solution must adhere to the principle of least privilege.

Which permissions are required to ensure that you can commit code to GitHub?

You have a Fabric workspace that includes a lakehouse named Lakehouse1.

An external data source contains data files that are 500 GB each. One new file is added every day.

You need to ingest the data into Lakehouse1 without applying transformations. The solution must meet these requirements:

• Trigger the process when a new file is added.
• Provide the highest throughput.

Which type of item should you use to ingest the data?

HOTSPOT

You need to recommend a Fabric streaming solution that uses the sources shown in the following table.

The solution must minimize development effort.

What should the recommendation include for each source?

You have a Fabric workspace named Workspace1 that includes an Apache Spark job definition named Job1.

You have an Azure SQL database named Source1 with public internet access disabled.

You need to ensure that Job1 can access the data in Source1.

What should you create?

You have a Fabric workspace named Workspace1.

You plan to integrate Workspace1 with Azure DevOps.

You will use a Fabric deployment pipeline named deployPipeline1 to deploy items from Workspace1 to higher-environment workspaces as part of a medallion architecture. You will run deployPipeline1 by using an API call from an Azure DevOps pipeline.

You need to configure API authentication between Azure DevOps and Fabric.

Which authentication type should you use?

You have a Fabric warehouse named DW1. DW1 includes a table that stores sales data and is used by several sales representatives.

You plan to implement row-level security (RLS).

You need to ensure that sales representatives can view only their own data.

Which warehouse object is required to implement RLS?

What should you do to improve the query experience for the business users?

Solution: You use the following code segment:

Does this satisfy the goal?

Solution: You use the following code segment:

Does this satisfy the goal?

Solution: Use the following code segment:

Does this fulfill the goal?