Skip to main content

Copy data from any source to any destination without any code


ingestr is a command-line app that allows you to ingest data from any source into any destination using simple command-line flags, no code necessary.

  • โœจ copy data from your database into any destination
  • โž• incremental loading: append, merge or delete+insert
  • ๐Ÿ single-command installation

ingestr takes away the complexity of managing any backend or writing any code for ingesting data, simply run the command and watch the data land on its destination.

MongoDB to Postgres benchmark

Installation

You can install ingestr using the install script:

curl -LsSf https://getbruin.com/install/ingestr | sh

Alternatively, you can install it with pip:

pip install ingestr

The pip package can also be used from Python. Install the SDK extra for Python data ingestion:

pip install 'ingestr[sdk]'

Python rows, generators, and DataFrames are sent to the bundled ingestr binary as Arrow IPC streams by default:

import ingestr

ingestr.ingest(
    [{"id": 1, "name": "Ada"}, {"id": 2, "name": "Grace"}],
    dest_uri="duckdb:///tmp/warehouse.duckdb",
    dest_table="main.people",
)

DataFrames and yielded data use the same Arrow stream transport:

ingestr.ingest(df, dest_uri="duckdb:///tmp/warehouse.duckdb", dest_table="main.events")

def events():
    yield [{"id": 1, "event": "signup"}]
    yield [{"id": 2, "event": "purchase"}]

ingestr.ingest(events, dest_uri="postgresql://...", dest_table="public.events")

For push-style code, omit the data argument and use ingest as a context manager. The context value accepts the same shapes as ingestr.ingest(data, ...):

with ingestr.ingest(dest_uri="postgresql://...", dest_table="public.events") as ingest:
    for response in client.list_events():
        ingest(response["items"])

For very large already-materialized data, use the existing mmap Arrow IPC file transport:

ingestr.ingest(df, dest_uri="duckdb:///tmp/warehouse.duckdb", dest_table="main.events", transport="mmap")

For full CLI pass-through, use ingestr.run(["ingest", "--source-uri", "...", "--dest-uri", "...", "--source-table", "..."]), or ingestr.run_cli(...) for keyword arguments that map to CLI flags.

Quickstart

ingestr ingest \
    --source-uri 'postgresql://admin:admin@localhost:8837/web?sslmode=disable' \
    --source-table 'public.some_data' \
    --dest-uri 'bigquery://<your-project-name>?credentials_path=/path/to/service/account.json' \
    --dest-table 'ingestr.some_data'

That's it.

This command:

  • gets the table public.some_data from the Postgres instance.
  • uploads this data to your BigQuery warehouse under the schema ingestr and table some_data.

Documentation

You can see the full documentation here.

Community

Join our Slack community here.

Contributing

Pull requests are welcome. However, please open an issue first to discuss what you would like to change. We maybe able to offer you help and feedback regarding any changes you would like to make.

[!NOTE] After cloning ingestr make sure to run make setup to install githooks.

Supported sources & destinations

Source Destination CDC
Databases
AWS Athena โœ… โœ… -
Apache Iceberg - โœ… -
AWS Redshift โœ… โœ… -
Cassandra โœ… โœ… -
ClickHouse โœ… โœ… -
Couchbase โœ… - -
CrateDB โœ… โœ… -
Databricks โœ… โœ… -
DuckDB โœ… โœ… -
DynamoDB โœ… โœ… -
Elasticsearch โœ… โœ… -
Google BigQuery โœ… โœ… -
GCP Spanner โœ… - -
IBM Db2 โœ… - -
InfluxDB โœ… - -
Kafka โœ… - -
Local CSV file โœ… โœ… -
MaxCompute โœ… โœ… -
Microsoft Fabric โœ… โœ… -
Microsoft OneLake - โœ… -
Microsoft SQL Server โœ… โœ… โœ…
MongoDB โœ… โœ… โœ…
MotherDuck โœ… โœ… -
MySQL โœ… โœ… โœ…
Oracle โœ… - -
PlanetScale โœ… โœ… โœ…
Postgres โœ… โœ… โœ…
RabbitMQ โœ… - -
SAP Hana โœ… - -
Snowflake โœ… โœ… -
Socrata โœ… - -
SQLite โœ… โœ… -
StarRocks โœ… โœ… -
Synapse - โœ… -
Trino โœ… โœ… -
Vitess โœ… โœ… โœ…
Platforms
Adjust โœ… - -
Adapty โœ… - -
Airtable โœ… - -
Allium โœ… - -
Amazon Kinesis โœ… - -
Anthropic โœ… - -
API-Football โœ… - -
AppsFlyer โœ… - -
Apple Ads โœ… - -
Apple App Store โœ… - -
Applovin โœ… - -
Applovin Max โœ… - -
Asana โœ… - -
Attio โœ… - -
Azure Data Lake Storage Gen2 โœ… โœ… -
BallDontLie FIFA โœ… - -
Braze โœ… - -
Bruin โœ… - -
Chess.com โœ… - -
ClickUp โœ… - -
Cursor โœ… - -
Docebo โœ… - -
Dune โœ… - -
Facebook Ads โœ… - -
Fireflies โœ… - -
Fluxx โœ… - -
football-data.org โœ… - -
Frankfurter โœ… - -
Freshdesk โœ… - -
FundraiseUp โœ… - -
G2 โœ… - -
GitHub โœ… - -
GitLab โœ… - -
Google Ads โœ… - -
Google Analytics โœ… - -
Google Cloud Storage (GCS) โœ… โœ… -
Google Sheets โœ… - -
Gorgias โœ… - -
Granola โœ… - -
Hostaway โœ… - -
HubSpot โœ… - -
Indeed โœ… - -
Intercom โœ… - -
Internet Society Pulse โœ… - -
Jira โœ… - -
JobTread โœ… - -
Klaviyo โœ… - -
Linear โœ… - -
LinkedIn Ads โœ… - -
Mailchimp โœ… - -
Mixpanel โœ… - -
Monday โœ… - -
Notion โœ… - -
Paddle โœ… - -
Personio โœ… - -
PhantomBuster โœ… - -
Pinterest โœ… - -
Pipedrive โœ… - -
Plus Vibe AI โœ… - -
PostHog โœ… - -
Primer โœ… - -
QuickBooks โœ… - -
Reddit Ads โœ… - -
RevenueCat โœ… - -
S3 โœ… โœ… -
Salesforce โœ… - -
SFTP โœ… - -
SendGrid โœ… - -
Shopify โœ… - -
Slack โœ… - -
Smartsheet โœ… - -
Snapchat Ads โœ… - -
Solidgate โœ… - -
Square โœ… - -
Stripe โœ… - -
SurveyMonkey โœ… - -
TikTok Ads โœ… - -
Trello โœ… - -
Trustpilot โœ… - -
Twilio โœ… - -
Wise โœ… - -
Zendesk โœ… - -
Zoom โœ… - -

Feel free to create an issue if you'd like to see support for another source or destination.

License

ingestr is source-available under the Functional Source License 1.1, with Apache 2.0 as the future license. You can use ingestr freely for internal production use, development, testing, education, research, and professional services. You cannot use ingestr to offer a competing commercial ingestion, ELT, connector, or managed data pipeline product/service.

Each version becomes Apache 2.0 two years after release.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distributions

If you're not sure about the file name format, learn more about wheel file names.

ingestr-1.1.9-py3-none-win_amd64.whl (81.0 MB view details)

Uploaded Python 3Windows x86-64

ingestr-1.1.9-py3-none-manylinux2014_x86_64.whl (80.9 MB view details)

Uploaded Python 3

ingestr-1.1.9-py3-none-manylinux2014_aarch64.whl (71.8 MB view details)

Uploaded Python 3

ingestr-1.1.9-py3-none-macosx_11_0_arm64.whl (73.0 MB view details)

Uploaded Python 3macOS 11.0+ ARM64

ingestr-1.1.9-py3-none-macosx_10_15_x86_64.whl (80.3 MB view details)

Uploaded Python 3macOS 10.15+ x86-64

File details

Details for the file ingestr-1.1.9-py3-none-win_amd64.whl.

File metadata

  • Download URL: ingestr-1.1.9-py3-none-win_amd64.whl
  • Upload date:
  • Size: 81.0 MB
  • Tags: Python 3, Windows x86-64
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.11.15

File hashes

Hashes for ingestr-1.1.9-py3-none-win_amd64.whl
Algorithm Hash digest
SHA256 0c5436e83c9eeac1bb33c549c3d8e4851be5daa492e6c61be12bfe63c71c4949
MD5 34269a546192edf7c3bca314d492c6af
BLAKE2b-256 665054f4bb7397657af6f75574fb6528dda0f1ed0afff7968f439469bb632839

See more details on using hashes here.

File details

Details for the file ingestr-1.1.9-py3-none-manylinux2014_x86_64.whl.

File metadata

File hashes

Hashes for ingestr-1.1.9-py3-none-manylinux2014_x86_64.whl
Algorithm Hash digest
SHA256 bb83f58cccbd7688c8baa1d98507263d63bdbc0355d2d8765b97729424a56d46
MD5 d7c955c46a00faa179c7ee7b7588e2eb
BLAKE2b-256 f162be0b4472a9c97a8bc30a0fe3f4ff2502850107457e330115aa24d70f69cd

See more details on using hashes here.

File details

Details for the file ingestr-1.1.9-py3-none-manylinux2014_aarch64.whl.

File metadata

File hashes

Hashes for ingestr-1.1.9-py3-none-manylinux2014_aarch64.whl
Algorithm Hash digest
SHA256 4bb57f3a6f188d36f61dcea2ecdab4727de3e4a1478eb81b59ec2ffb6acc3154
MD5 8e618d9cffe647257c7e24b2609193d9
BLAKE2b-256 61e87a24903ad5a493b6623b2492a2d11a15980a32ab265bf31e94573e8d292d

See more details on using hashes here.

File details

Details for the file ingestr-1.1.9-py3-none-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for ingestr-1.1.9-py3-none-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 b905d71f89758cb3ab8688cf22a1d722c45ed265bf88937c566687db5d72644a
MD5 802ede5fde251142ba3887f95cdb5521
BLAKE2b-256 53d510e33963eae779867b8eb0454a5d55dcca506e4a27e862a9303da3365ec6

See more details on using hashes here.

File details

Details for the file ingestr-1.1.9-py3-none-macosx_10_15_x86_64.whl.

File metadata

File hashes

Hashes for ingestr-1.1.9-py3-none-macosx_10_15_x86_64.whl
Algorithm Hash digest
SHA256 45965d3c4b9a5de24b3f83435bd36f009a2830ba3b2d2f52ef715a79285ba027
MD5 6889384cd495187eba989c81d7c15f93
BLAKE2b-256 7614b0a3ebbfaa1fb50ab545ae2725539309db9ca1b6a6cfe6a9c82f8c88ecb9

See more details on using hashes here.

Release history Release notifications | RSS feed

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page