Skip to main content

Data Ingestion with Lakeflow Connect

This course provides a comprehensive introduction to Lakeflow Connect, a scalable and simplified solution for ingesting data into Databricks from a wide range of sources. You’ll begin by exploring the different types of Lakeflow Connect connectors (Standard and Managed) and learn various data ingestion techniques, including batch, incremental batch, and streaming ingestion. You'll also review the key benefits of using UC table and the Medallion architecture


Next, you’ll develop practical skills for ingesting data from cloud object storage using Lakeflow Connect Standard Connectors. This includes working with methods such as CREATE TABLE AS SELECT (CTAS), COPY INTO, and Auto Loader, with an emphasis on the benefits and considerations of each approach. You’ll also learn how to append metadata columns to your bronze-level tables during ingestion into the Databricks Data Intelligence Platform. The course then covers how to handle records that don’t match your table schema using the rescued data column, along with strategies for managing and analyzing this data. You’ll also explore techniques for ingesting and flattening semi-structured JSON data.


Following this, you’ll explore how to perform enterprise-grade data ingestion using Lakeflow Connect Managed Connectors to bring in data from databases and Software-as-a-Service (SaaS) applications. The course also introduces Partner Connect as an option for integrating partner tools into your ingestion workloads.


Finally, the course wraps up with alternative ingestion strategies, including MERGE INTO operations and leveraging the Databricks Marketplace, equipping you with a strong foundation to support modern data engineering use cases.


Note: For SCORM lecture files, please ensure that you close the SCORM window after completing the content. Do not click the ‘Next Lesson’ button, as doing so may prevent the SCORM module from being marked as complete.

Skill Level
Associate
Duration
2h
Prerequisites

In this course, the content was developed for participants with these skills/knowledge/abilities: 

• Basic understanding of the Databricks Data Intelligence platform, including Databricks Workspaces, Apache Spark, Delta Lake, the Medallion Architecture and Unity Catalog.

• Basic understanding of data ingestion workflows (batch, streaming, incremental) and general ETL principles

• Experience working with various file formats (e.g., Parquet, CSV, JSON, TXT).

• Proficiency in SQL and Python.

• Familiarity with running code in Databricks notebooks.

Self-Paced

Custom-fit learning paths for data, analytics, and AI roles and career paths through on-demand videos

See all our registration options

Registration options

Databricks has a delivery method for wherever you are on your learning journey

Runtime

Self-Paced

Custom-fit learning paths for data, analytics, and AI roles and career paths through on-demand videos

Register now

Instructors

Instructor-Led

Public and private courses taught by expert instructors across half-day to two-day courses

Register now

Learning

Blended Learning

Self-paced and weekly instructor-led sessions for every style of learner to optimize course completion and knowledge retention. Go to Subscriptions Catalog tab to purchase

Purchase now

Scale

Skills@Scale

Comprehensive training offering for large scale customers that includes learning elements for every style of learning. Inquire with your account executive for details

Upcoming Public Classes

Get Started with Databricks for Data Engineering - Mandarin Chinese

本课程介绍在 Databricks Data Intelligence Platform 上执行基本数据工程工作流所需的基础技能。您将浏览 workspace,使用 Unity Catalog,并学习数据工程师在 Databricks 上日常使用的核心构建模块。

本课程采用实践路径。您从熟悉 workspace 开始,然后针对每个主题完成配套的演示笔记本和实验室笔记本。演示部分将由讲师或引导式笔记本带您了解相关概念。

课程内容涵盖:

Databricks Data Intelligence Platform,以及 Databricks workspace、Unity Catalog 和笔记本之间的协作关系。

创建和管理 Delta Lake 表。

使用 INSERT、UPDATE 和 DELETE 修改数据。

浏览 UC 表的版本历史与 time travel 功能。

使用 LakeFlow Connect 的多种方式摄取数据:CTAS、上传 UI 以及 COPY INTO。

构建奖章架构管道,将数据依次经过铜牌、银牌和金牌层进行转换。

使用 LakeFlow Jobs 实现管道自动化。

(附加内容)使用 Apache Spark™ Declarative Pipelines 构建声明式管道。

完成本课程后,您将能够熟练创建 Delta Lake 表、向其中摄取数据、通过奖章管道对数据进行转换,并将整个流程自动化为定时任务。

注意:Databricks Academy 正在将 Databricks 环境中的课堂课程转为基于 notebook 的形式,并停止在讲座中使用幻灯片。您可以在 Vocareum 实验环境中访问课程 notebook。

Free
2h
instructor-led
Onboarding

Questions?

If you have any questions, please refer to our Frequently Asked Questions page.