Data Ingestion
Database to Data Lake ETL
★ 3.5
Open Source Message Broker
★ 4.6
pip install db2lakepip install pikapip install db2lakepip install pikaPython data engineers use db2lake to bootstrap data lake migration projects — extracting historical data from relational databases and writing it as partitioned Parquet files to S3 or HDFS. Once the initial migration is done, incremental extractions keep the lake in sync, and Python-based PySpark or DuckDB pipelines take over for ongoing processing.
Python data engineers use `pika` or `aio-pika` to connect pipelines to RabbitMQ. A common pattern is a Python producer that publishes enriched records to a topic exchange after transformation, and multiple consumer processes that subscribe to routing key patterns for parallel downstream processing. RabbitMQ's dead-letter queues handle failed processing with configurable retry logic.
Individual Tool Pages