Documentation
Everything you need to build, deploy, and monitor data pipelines with DataForge.
Transformations
Quick Example: PostgreSQL to Snowflake
from dataforge import Pipeline, PostgresSource, SnowflakeDestination
pipeline = Pipeline(name="users-sync")
# Configure source
source = PostgresSource(
host="db.example.com",
database="production",
table="users",
incremental_key="updated_at"
)
# Configure destination
destination = SnowflakeDestination(
warehouse="COMPUTE_WH",
database="ANALYTICS",
schema="RAW"
)
# Run pipeline
pipeline.extract(source).load(destination).run()Need Help?
Can't find what you're looking for? Our team is here to help.