Data Engineer Associate · Domain 2: Data Ingestion and Loading · 21% of the exam
Task 2.6: Prioritize between Auto Loader, Lakeflow Connect (standard and managed connectors), partner connectors, and other ingestion methods based on technical requirements such as data volume, ingestion frequency, data types, and governance needs with Unity Catalog.
Starting from the most managed layer and dropping down only when a requirement forces it: managed connectors, Auto Loader and streaming tables, COPY INTO, Partner Connect tools, Lakehouse Federation and custom code.
Study it
Choosing an ingestion method: managed connectors, Auto Loader, COPY INTO, partners, federation
Lesson coming
Sample questions
Try each one before opening the answer. Every option is explained, with the Databricks documentation page that proves it.
Question 1 · choose 2
A MySQL database holds orders tables with an updated_at column that increases whenever a row changes. The database team refuses to enable binary logging or grant replication access. Silver tables in Unity Catalog must be refreshed incrementally every night. Which TWO approaches meet these requirements? (Choose TWO.)
AThe Lakeflow Connect MySQL database connector with an ingestion gateway
BA Lakeflow Connect query-based connector using updated_at as the cursor column
CAn Auto Loader stream pointed at the MySQL host
DA COPY INTO statement that uses the MySQL JDBC URL as its source
EA nightly notebook job that reads rows by updated_at over JDBC and merges them
Show the answer and why
AThe Lakeflow Connect MySQL database connector with an ingestion gateway
Incorrect
The managed MySQL database connector ingests with change data capture from the binary log, which the database team will not enable.
BA Lakeflow Connect query-based connector using updated_at as the cursor column
Correct
Query-based connectors query the source directly and use a monotonically increasing cursor column to fetch new and changed rows, with no CDC setup.
CAn Auto Loader stream pointed at the MySQL host
Incorrect
Auto Loader is a cloud object storage source; it discovers files, not database rows.
DA COPY INTO statement that uses the MySQL JDBC URL as its source
Incorrect
COPY INTO loads files from a cloud storage location or volume, not tables from a database connection.
EA nightly notebook job that reads rows by updated_at over JDBC and merges them
Correct
A JDBC read filtered on the cursor column, merged into the silver table and scheduled with Lakeflow Jobs, also works without CDC, with more code to maintain.
Without binary logs, CDC-based connectors are out. A query-based connector, or a custom JDBC read on the same kind of cursor column, can still pick up new and changed rows on a schedule.
An internal HR system exposes only a REST API, and Lakeflow Connect has no managed connector for it. The data team wants to write the ingestion logic itself and run it as a Lakeflow Connect connector in its own workspace, without registering or publishing the code anywhere. Which option fits?
AA Lakehouse Federation connection to the HR system's API
BAn OpenSharing recipient that receives the HR data
CA Lakeflow Connect query-based connector on the HR API
DA custom connector for Lakeflow Connect, built in the workspace
Show the answer and why
AA Lakehouse Federation connection to the HR system's API
Incorrect
Query federation reaches external relational databases over JDBC for read-only queries; it does not ingest from a REST API.
BAn OpenSharing recipient that receives the HR data
Incorrect
OpenSharing shares data that a provider manages with other organizations; it does not pull data out of an internal API.
CA Lakeflow Connect query-based connector on the HR API
Incorrect
Query-based connectors ingest from databases by querying the source database directly; an HTTP API is not a database they can query.
DA custom connector for Lakeflow Connect, built in the workspace
Correct
Custom connectors let a team build its own connector for a source with no managed connector, and build, test, deploy and run it in its own workspace without registering it with the community.
Lakeflow Connect covers sources at several layers: managed connectors for popular applications and databases, connectors shared by the community, and custom connectors that a team builds and runs privately in its own workspace for a source nothing else covers.
A partner sends a one-off 300 MB .zip archive that holds 40 CSV files, all with the same columns. They must become one managed Delta table in Unity Catalog. The data engineer can write to the volume /Volumes/main/landing/partner and has a notebook. Which approach works?
AUpload the .zip on the Create or modify a table using file upload page
BExpand it with unzip in a %sh cell, then load the CSVs from the volume
CExtract it on a laptop and upload the 40 CSVs on the file upload page
DLoad the .zip from the volume with COPY INTO and FILEFORMAT = BINARYFILE
Show the answer and why
AUpload the .zip on the Create or modify a table using file upload page
Incorrect
The file upload page does not support compressed files such as zip and tar files.
BExpand it with unzip in a %sh cell, then load the CSVs from the volume
Correct
The unzip Bash command, run with the %sh magic command, expands .zip files; the CSV files can then be read from the volume with the standard CSV options and written to the table.
CExtract it on a laptop and upload the 40 CSVs on the file upload page
Incorrect
The file upload page accepts up to 10 files at a time, and each upload creates a new table or overwrites one rather than appending to it.
DLoad the .zip from the volume with COPY INTO and FILEFORMAT = BINARYFILE
Incorrect
The binary file source turns each file into a single record of raw content and metadata, so the archive becomes one row, not CSV rows.
The file upload page rejects compressed files and caps an upload at 10 files. Databricks documents expanding .zip files with the unzip command from a %sh cell; once the extracted CSV files sit in a volume, they load into the table with the usual CSV reader options.
Analysts want to run a few ad hoc queries against a PostgreSQL database for a proof of concept. The data must not be copied into Databricks, and the queries must be governed by Unity Catalog. Which option fits?
AA Lakeflow Connect managed PostgreSQL connector
BA nightly notebook that reads the tables over JDBC into Delta
CLakehouse Federation with a foreign catalog for the database
DOpenSharing from the PostgreSQL database
Show the answer and why
AA Lakeflow Connect managed PostgreSQL connector
Incorrect
Managed connectors copy data into Databricks tables, which the requirement rules out.
BA nightly notebook that reads the tables over JDBC into Delta
Incorrect
This copies data and needs code and a schedule.
CLakehouse Federation with a foreign catalog for the database
Correct
Federation queries external sources in place, without moving data, and the managed connector FAQ points to it for ad hoc reporting and proofs of concept.
DOpenSharing from the PostgreSQL database
Incorrect
OpenSharing shares data that a provider publishes; it does not query an operational PostgreSQL database.
Ingestion copies data for scale and performance; Lakehouse Federation leaves it in place, which suits ad hoc and proof-of-concept work.
A company wants to try a third-party ingestion partner for sources that Lakeflow Connect does not cover. It wants Databricks to create the SQL warehouse, service principal and token the partner needs, and then connect to a new trial account. What should the workspace admin use?
APartner Connect, starting from the partner's tile
BA community connector registered in Lakeflow Connect
CA custom connector built for Lakeflow Connect
DAn OpenSharing recipient created for the partner
Show the answer and why
APartner Connect, starting from the partner's tile
Correct
Partner Connect provisions the SQL warehouse, a service principal and a personal access token for the partner, then hands off to the partner's trial sign-up.
BA community connector registered in Lakeflow Connect
Incorrect
A community connector is connector code for a source; it does not create a warehouse, service principal and token for a partner's trial.
CA custom connector built for Lakeflow Connect
Incorrect
A custom connector is a Lakeflow Connect connector for a source; it does not connect a third-party product or set up its warehouse and token.
DAn OpenSharing recipient created for the partner
Incorrect
OpenSharing shares data from Databricks with other platforms; it does not set up a partner's ingestion tool.
Partner Connect is the shortcut to connect validated partner tools with new trial accounts. For an existing partner account, Databricks recommends connecting manually.