From PostgreSQL to Fabric using Microsoft OneLake

Configure your LakeXpress data pipeline with the selected components

LX

LakeXpress Orchestrator

  • Manages end-to-end pipelines
  • Orchestrates FastBCP extracts with retries & logging
  • Handles incremental sync and schema-aware metadata
Control DB for increments/custom rules & logsMetadata-drivenLinux or Windows
FastBCP
FastBCPEngine
Terminal
./LakeXpress config create \
  -a data/ds_credentials.json \
  --log_db_auth_id log_db_ms \
  --source_db_auth_id datasource_postgresql_01 \
  --source_db_name sales \
  --source_schema_name "sales,dim" \
  --fastbcp_dir_path ./FastBCP_linux-x64/latest/ \
  --fastbcp_p 2 \
  --n_jobs 4 \
  --target_storage_id onelake_lake_prd \
  --generate_metadata \
  --sub_path /ingest/bronze \
  --incremental_table "sales.orders:o_orderdate:date" \
  --incremental_table "sales.lineitem:l_shipdate:date" \
  --publish_method internal \
  --publish_target fabric_tgt

# First sync - full load
./LakeXpress sync

# Subsequent syncs - incremental updates (much faster!)
./LakeXpress sync
Get LakeXpress

Source - PostgreSQL

PostgreSQL is a powerful and robust open-source relational database. LakeXpress optimizes extractions from PostgreSQL using FastBCP's native connector for excellent performance.

Features:

  • Direct streaming read from database
  • Full support for PostgreSQL data types
  • Secure SSL connections
  • Parallel extraction to Parquet

Format - Apache Parquet

Parquet is the industry-standard columnar file format for analytics. LakeXpress uses FastBCP to extract data from source databases and convert it to Parquet format, ensuring optimal compression, query performance, and compatibility with all modern data platforms.

Advantages:

  • Columnar format optimized for analytics
  • Efficient compression (typically 3-10x)
  • Schema evolution support
  • Predicate pushdown for fast queries
  • Universal compatibility with cloud platforms
  • Preserves data types and precision

Cloud Stage - Microsoft OneLake

OneLake is Microsoft Fabric's unified data lake. LakeXpress stages data directly in OneLake, providing native integration with all Fabric workloads and eliminating data duplication.

Features:

  • Native Fabric integration
  • Single copy of data across all workloads
  • Automatic Delta Lake format
  • Built-in governance and security
  • Seamless data sharing across Fabric

Destination - Microsoft Fabric

Microsoft Fabric is an all-in-one analytics solution. LakeXpress publishes data directly into Fabric lakehouses or warehouses with native OneLake integration.

Publishing method:

OneLake Delta Lake or SQL Analytics Endpoint

Features:

  • Native OneLake integration
  • Automatic Delta Lake conversion
  • Direct query from Power BI
  • Unified governance
  • Real-time analytics