■ Pipelines
8 pipelines — 1 running, 1 errors
sales_analytics_daily
Sync sales orders, customers, and products from PostgreSQL to Snowflake for BI dashboards.
user_events_stream
Real-time streaming of user behaviour events from Kafka into BigQuery for product analytics.
inventory_sync
Pull product inventory from REST API every 2 hours and upsert into operational MySQL database.
marketing_attribution
Joins ad spend data from multiple sources, applies attribution model, loads to Redshift.
product_catalog_export
Nightly export of full product catalog from MongoDB to S3 in Parquet format.
finance_ledger_sync
Sync accounting ledger from MySQL to BigQuery for finance reporting. PII anonymised in transit.
crm_contacts_delta
Incremental sync of CRM contact changes from Salesforce into internal PostgreSQL replica.
log_archive
Archive CloudWatch application logs to S3 Glacier for long-term retention and compliance.