Integrations

Connect every source. Keep it in sync.

Synchronoid ships with connectors for databases, warehouses, object storage, streams and SaaS apps. Each one shares the same retries, rate limits and provenance, so a new source behaves like the ones you already run.

Request access How connectors work

PostgreSQL GA

Relational database. Incremental and full-table reads.

View details →

MySQL GA

Read tables from MySQL and MariaDB with incremental cursors.

Snowflake GA

Load published data into Snowflake or read tables as sources.

View details →

BigQuery GA

Write published tables and read query results from BigQuery.

View details →

Amazon S3 GA

Read files from buckets and keep raw payloads in your own bucket.

View details →

Google Cloud Storage GA

Read and write objects in Cloud Storage buckets.

SFTP / CSV GA

Pick up CSV and fixed-width files from partner SFTP servers.

Apache Kafka Beta

Consume topics as sources and publish change events to topics.

View details →

{ }

HTTP / REST (JSON) GA

The generic connector for any JSON API, with paging and rate limits.

View details →

GraphQL Beta

Query GraphQL endpoints with cursor-based paging.

Webhooks GA

Receive events as a source, or send signed change events to your apps.

Salesforce Beta

Sync objects such as accounts and opportunities with the Bulk API.

HubSpot Beta

Read contacts, companies and deals with incremental updates.

Stripe Beta

Pull charges, invoices and payouts for reconciliation pipelines.

dbt Beta

Run dbt projects as assets and see models in the lineage graph.

View details →

Airbyte (import) Beta

Import existing Airbyte connection definitions into a project.

Databricks Coming soon

Delta tables as sources and destinations.

Amazon Redshift Beta

Unload and load published tables with Redshift.

ClickHouse Beta

Read from and write to ClickHouse tables with batched inserts.

DuckDB Beta

Local development destination and Parquet reads.

Slack (alerts) GA

Send run failures and paused-source alerts to channels.

PagerDuty (alerts) GA

Page the on-call engineer when a source is paused.

OpenTelemetry Beta

Export traces and metrics for runs and steps.

Status labels: GA means generally available inside the private beta and covered by support. Beta connectors work in production workspaces but may change. Coming soon connectors are on the roadmap.

Extensible

Don’t see your source? Build a connector.

A connector is a small Python class that knows how to fetch pages of data and say where it left off. Synchronoid takes care of scheduling, retries, rate limits, raw storage and provenance.

One connector type can serve many sources and accounts
The generic HTTP connector covers most JSON APIs with only YAML
Test connectors locally with syn dev before you deploy

Read about sources Request an integration

connectors/registry.py

import synchronoid as sy
from synchronoid.connectors import Connector, Page

@sy.connector(name="registry")
class RegistryConnector(Connector):
    def fetch(self, request, cursor=None) -> Page:
        resp = self.http.get("https://registry.example.org/api/companies", params={"after": cursor})
        body = resp.json()
        return Page(records=body["items"], next_cursor=body.get("next"))

Ready to stop babysitting pipelines?

Synchronoid is in private beta. Tell us about your data and we will get you a workspace.

Request access Book a demo