Sync your data
in real-time.

import { DataSynch } from '@datasynch/sdk';

// Initialize connection
const client = new DataSynch(process.env.API_KEY);

// Sync Postgres to Snowflake in real-time
await client.pipeline.create({
  source: 'postgres-prod',
  destination: 'snowflake-analytics',
  mode: 'cdc', // Change Data Capture
  transform: (row) => ({
    ...row,
    synced_at: new Date()
  })
});

// Output: Pipeline active. Latency: 45ms