Ingesta de datos

Introducción a Databricks SQL

Kevin Barlow

Data Manager

Motivación

Diagrama de flujo del lakehouse

Introducción a Databricks SQL

Crear el lakehouse

Diagrama de flujo del lakehouse - Ingesta

Introducción a Databricks SQL

Opciones basadas en GUI

Lakeflow Connect

  • Conectores integrados para ingerir datos
    • Bases de datos
    • Aplicaciones SaaS
  • Crea pipelines para mantener los datos actualizados

Lakeflow Connect

Carga de datos

  • Sube tus archivos manualmente
    • CSV, Parquet, etc.
  • Crea tablas Delta rápidamente
  • Ideal para cargas ad hoc

Carga de datos manual

Introducción a Databricks SQL

Cómo traer datos al lakehouse

COPY INTO

  • Copia datos del almacenamiento de objetos en la nube directamente en tablas Delta
  • Mejor para datasets más estáticos
  • Puede ejecutarse de forma nativa en SQL Editor
COPY INTO my_table
FROM '/path/to/files'
FILEFORMAT = PARQUET
FORMAT_OPTIONS ('mergeSchema' = 'true')
COPY_OPTIONS ('mergeSchema' = 'true')

Auto Loader

  • Ingeste automáticamente nuevos archivos desde el almacenamiento en la nube
  • Mejor para datasets grandes y cambiantes
  • Usa Delta Live Tables en SQL
CREATE TABLE customers
AS SELECT * 
FROM cloud_files(
  "/path/to/files", 
  "csv")
Introducción a Databricks SQL

¡Vamos a practicar!

Introducción a Databricks SQL

Preparing Video For Download...