Data Ingestion
Universal Data Ingestion Framework
★ 3.9
Stream Storage System
★ 3.7
N/A — Java-basedpip install pravega-clientN/A — Java-basedpip install pravega-clientPython data engineers interact with Gobblin by defining configuration files that specify source, extractor, converter, and writer plugins — executed as a Hadoop or standalone Java job. Python orchestration scripts manage Gobblin execution via REST API, monitor job completion, and process ingested output files with PySpark for downstream transformation and loading.
Python data engineers use the `pravega-grpc-gateway` or Python client to produce durable event streams to Pravega. Unlike Kafka, Pravega retains streams indefinitely with cost-tiered storage — Python pipelines use this for event sourcing architectures where the full history of events must be replayable for reprocessing after logic changes.
Individual Tool Pages