dlt-hub/dlt

Features

• Data Extraction Pipelines - Provides a unified loading pipeline to extract and synchronize data from APIs, databases, and cloud storage.
• Data Ingestion Pipelines - Automates the extraction, transformation, and loading of data from APIs, databases, and cloud storage into structured destinations.
• Automated Structure Normalization - Infers schemas and data types while flattening nested data structures into structured datasets.
• Schema Inference - Scans incoming data to dynamically generate relational table structures by flattening nested dictionaries and lists.
• ETL Code Generation - Automatically writes extraction and loading code for REST APIs using structured context assets.
• AI-Powered Pipeline Generators - Uses large language models to scaffold extraction code and connectors for REST APIs based on source definitions.
• Pipeline Scaffolding - Provides an AI assistant to guide users through source discovery and pipeline scaffolding for production data ingestion.
• Ingestion - Generates and deploys data ingestion pipelines using LLMs to accelerate connector development.
• Automatic Type Detection - Detects column data types from values using detector functions and preferred type rules.
• Relational Data Transformations - Transforms hierarchical JSON structures into a set of linked parent and child tables using row keys.
• Data Ingestion Tools - Provides a Python-based utility for importing data from diverse sources into lakehouses, warehouses, and vector databases.
• Automated Ingestion State Management - Tracks state and normalizes schemas to update destination tables without re-processing entire datasets.
• Data Quality Contracts - Enforces data contracts and quality standards to ensure the integrity and accuracy of loaded datasets.
• ETL Workflows - Pushes processed data into storage targets or custom endpoints to enable automated ETL workflows.
• Data Destination Connectors - Provides connectors to write extracted data into relational databases like Postgres, MySQL, and BigQuery.
• Data Schema Definitions - Specifies metadata and data types to structure how data is loaded into a destination.
• Data Schema Management - Provides programmatic definition and lifecycle management for evolving data models and relational schemas.
• Data Loading Strategies - Determines whether new data appends to, replaces, or merges with existing tables.
• Data Type Detection Heuristics - Assigns data types using regex-based rules and detector functions to ensure consistency across diverse sources.
• Schema Evolution - Adapts destination tables by adding new columns or creating variant columns when data types change.
• Dataset Loading - Processes data from diverse sources and converts it into structured formats with automatic schema creation.
• External Data Writing - Provides capabilities to control if new data replaces existing sets, appends, or merges based on keys.
• File-Based Data Ingestion - Reads CSV, Parquet, or JSONL files from local disks or cloud storage.
• Cloud Object Storage - Reads data from cloud-based object stores or local filesystems for centralized loading into destinations.
• Idempotent Write Strategies - Ensures data consistency by managing how new records append, replace, or merge in destination tables.
• Incremental Data Loading - Tracks the state of the last load to process only new or modified records.
• Incremental Data Synchronization - Uses state tracking and cursors to fetch and merge only new or modified records since the last execution.
• Nested Attribute Flattening - Transforms Python dictionaries and lists into relational structures by flattening nested data.
• Plugin-Based ETL Frameworks - Provides a pluggable framework that automates schema evolution, incremental loading, and normalization for ETL workflows.
• SQL Database Ingestion - Extracts data from SQL databases to be loaded into structured destination datasets.
• Data Extraction - Enables the retrieval of records from relational databases via connectivity plugins for target loading.
• Table Definitions - Defines table structures including write dispositions and relationships between parent and nested tables.
• Write Disposition Strategies - Determines if incoming data replaces existing records, appends to the table, or merges based on primary keys.
• Data Pipeline State Tracking - Tracks incremental cursors and resource state to ensure data is loaded without duplication across runs.
• REST API Data Sources - Provides standardized abstractions for consuming data from REST and HTTP endpoints via ingestion pipelines.
• REST API Extraction - Implements automated data extraction from REST APIs with built-in support for pagination and authentication.
• Schema Type Inference - Automatically determines column data types using runtime analysis of input properties and regex rules.
• API Ingestion Scaffolding - Scaffolds extraction pipelines for API endpoints with built-in support for validation and reporting.
• Visual Data Explorers - Analyzes loaded datasets to create data profiles and interactive charts for exploratory analysis.
• Visual Data Exploration - Connects datasets to dashboards to automatically generate charts based on the inferred schema.
• Schema Exports - Saves schema definitions as files to enable manual modification and version tracking.
• Python Data Structure Ingestion - Provides the ability to ingest data directly from Python generators and native structures into structured datasets.
• Column-Based Syncing - Tracks a specific column to transfer only new or modified rows in subsequent runs.
• Data Quality Monitors - Executes predefined validation rules and quality metrics to monitor data health within processing pipelines.
• Schema Versioning - Uses content-hashes of schema definitions to detect manual changes and synchronize database structures.
• Cursor-Based Change Streaming - Uses cursors based on timestamps or IDs to load only data produced since the last execution.
• Load-Time Transformations - Processes data during extraction to add columns or remove sensitive information before loading.
• Interactive Transformation Interfaces - Provides interfaces to visualize data and execute transformations using Python and SQL.
• Warehouse-Side Transformations - Executes transformations within the destination warehouse to leverage remote compute power.
• Object Store Sinks - Writes extracted data exactly once to cloud object stores like S3 or GCS using configurable partitioning policies.
• Snowflake Connectors - Provides specialized connectors for transferring extracted datasets into Snowflake for analysis and reporting.
• Dataset Explorers - Provides a graphical interface to browse relational tables and execute queries using SQL or Python.
• Dimensional Data Modeling - Applies dimensional modeling to transform loaded data into structured formats.
• Domain Model Transformations - Converts raw data into a structured ontology using dimensional modeling and transformation functions.
• Lakehouse Ingestion Pipelines - Provides specialized ingestion workflows to persist data into lakehouse architectures like Delta Lake or Iceberg.
• Bucket File Listings - Extracts records from cloud buckets by identifying files via glob patterns.
• Global Schema Rule Configurations - Sets universal rules for applying hints and data types to columns via name matches or regular expressions.
• Automatic API Pagination Engines - Automatically iterates over multi-page API responses to retrieve all available data without manual configuration.
• Lazy Query Pipelines - Processes records using Python generators to move data without loading entire datasets into memory.
• Namespace Standardization - Translates Unicode identifiers and naming styles into destination-compatible namespaces.
• Pluggable Storage Backends - Routes processed data to diverse storage targets like lakehouses or vector databases via a unified interface.
• Production Data Pipeline Management - Runs data pipelines at scale with integrated project management and caching.
• Relational Data Modeling - Models relationships between root and nested tables by specifying custom primary or merge keys.
• Row-Key Table Linking - Links root and nested tables using row keys to maintain relational integrity.
• Loading Distribution Strategies - Assigns primary keys and partitions to columns to improve indexing and speed up data retrieval.
• Pipeline Scaffolding - Provides scaffolding to connect SQL databases to destinations and optimize backend performance.
• SQL Dialect Adapters - Extracts data from various SQL dialects and adapts it for loading into compatible destination databases.
• Vector Database Integrations - Integrates with vector search engines and multimodal databases to support AI and machine learning applications.
• Vector Ingestion - Ingests multimodal data and embeddings into vector search engines to support AI and machine learning applications.
• Vector Storage - Supports the ingestion of vectors, images, and audio into high-dimensional vector storage for AI retrieval.
• Incremental State Tracking - Records cursors and timestamps to minimize data transfer by loading only modified records.
• Custom Data Source Implementations - Enables the creation of custom extraction pipelines through Python code to fetch data from unsupported sources.
• Interactive Analysis Dashboards - Generates interactive Python notebooks based on analysis plans to visualize data trends and query results.
• Data Connector Libraries - Provides a library of maintained connectors to import data from common databases, APIs, and SaaS platforms.
• Pydantic Schema Validation - Utilizes Pydantic models to define schemas and validate individual data items before they are loaded.
• Table Maintenance Automations - Handles incremental loading and schema evolution automatically to ensure data consistency.
• Quality Validation Rules - Maps business requirements to specific quality check and metric calls to enforce consistency across tables.
• Type-Hint-Based Schema Definitions - Injects data types and metadata hints into resources during runtime to bypass static schema files.
• Pipeline Monitoring Dashboards - Provides a browser-based visual interface for tracking the status and health of data pipelines.
• Data Quality Validators - Implements programmatic validation rules and column expectations to ensure the accuracy of loaded datasets.
• Loaded Data Validation - Verifies that data is captured accurately by checking row counts and schema correctness via integrated dashboards.
• Interactive Dashboards - Transforms analytical notebooks into interactive web applications featuring UI elements and data charts.
• Column-Level Validation - Defines column-level validation rules to inspect schemas and diagnose data integrity failures during execution.
• Data Integration - Python library for building data pipelines as code with schema evolution.
• Data Pipelines - Library for building data pipelines with automatic schema inference.
• Workflow Development Tools - Library for building data pipelines with schema inference and loading.

Star 历史