Connectors

PipeKeel reads from and writes to these systems. Every connection is tested before you use it, credentials are stored write-only, and outbound connections can't reach private or internal addresses.

Warehouses

Google BigQuery — read tables in place or extracted; write by append, overwrite, merge (upsert) or SCD type 2. Keyless in Sovereign mode.

Databases

MySQL, PostgreSQL, Microsoft SQL Server, Oracle — read whole tables or only new and changed rows; write by append, overwrite or upsert. TLS with your provider's CA (Aiven, Cloud SQL). Private networks through the Runner.

Online stores

Shopify — orders, line items, customers, products, variants; tag customers, orders or products. WooCommerce — orders, line items, customers, products, coupons; update stock, prices and statuses. Shopify analytics · WooCommerce reporting

Streams

Google Pub/Sub — real time into BigQuery (subscriptions with message transforms) or micro-batches; publish rows. Apache Kafka — Confluent, MSK, Aiven, self-hosted; real time or micro-batches; produce rows. Pub/Sub · Kafka

Files

Cloud Storage, SFTP, files over HTTPS, uploads — CSV, JSON, JSON Lines and Parquet.

Apps and APIs

Google Sheets — read and write tabs. Any REST API — JSON, XML or CSV, paginated, with API keys, bearer, basic or OAuth 2.0; send rows back with POST, PUT, PATCH or DELETE. REST APIs

Also in every pipeline

59 blocks: joins, aggregates, windows, pivots, deduplication, JSON and XML parsing, masking personal data, data quality checks and custom SQL.
Workflows: run pipelines in order, call HTTP endpoints, run SQL scripts, send emails and Slack messages, branch on conditions.
PipeKeel Managed Storage: a warehouse table without a cloud account of your own (Express).