List
Read live records straight from the Shopify API.
Pull Shopify abandoned checkouts and articles into any warehouse or AI app.
Source
Shopify

Overview
The Airbyte Shopify connector extracts data from Shopify and loads it into 50+ destinations such as Snowflake, BigQuery, Databricks or Postgres, with full refresh and incremental sync. It publishes 38 streams you can select per connection.
Land 38 Shopify tables in 50+ destinations on a schedule you control.
Read, create, update and delete Shopify records at runtime through typed entity actions.
Query synced Shopify data with filters, sorting and semantic search, without spending Shopify API rate limits.
Pull only the records that changed since the last run instead of reloading everything.
38 streams
| Sync modes | FullIncr. |
|---|
| Sync modes | FullIncr. |
|---|
| Sync modes | FullIncr. |
|---|
| Sync modes | FullIncr. |
|---|
| Sync modes | FullIncr. |
|---|
| Sync modes | FullIncr. |
|---|
Setup
First, navigate to the Shopify source connector page on Airbyte's website.
Click on the "Add Source" button to begin the process of adding your Shopify credentials.
In the "Connection Configuration" section, enter your Shopify store URL.
Next, enter your Shopify API key and password in the appropriate fields.
Click on the "Test" button to ensure that your credentials are correct and that Airbyte can connect to your Shopify store.
If the test is successful, click on the "Save & Continue" button to proceed.
In the "Schema Selection" section, choose which Shopify data you want to replicate in Airbyte.
Click on the "Save & Continue" button to proceed.
In the "Destination" section, choose where you want to send your Shopify data.
Click on the "Create Connection" button to finalize the process and start replicating your Shopify data in Airbyte.
| Field | Type | Description |
|---|---|---|
| shop* | string | The name of your Shopify store found in the URL. For example, if your URL is https://NAME.myshopify.com, then the name is 'NAME'. You may also paste the full myshopify URL (e.g. https://NAME.myshopify.com) and it will be normalized automatically. |
| bulk_window_in_days | integer | Defines what would be a date range per single BULK Job |
| credentials | object | The authorization method to use to retrieve data from Shopify |
| fetch_transactions_user_id | boolean | Defines which API type (REST/BULK) to use to fetch Transactions data. If you are a Shopify Plus user, leave the default value to speed up the fetch. |
| fulfillment_orders_include_closed | boolean | If enabled, the Fulfillment Orders stream includes closed fulfillment orders. Shopify excludes closed orders by default. |
| job_checkpoint_interval | integer | The threshold, after which the single BULK Job should be checkpointed (min: 15k, max: 1M) |
| job_product_variants_include_pres_prices | boolean | If enabled, the Product Variants stream attempts to include Presentment prices field (may affect the performance). |
| job_termination_threshold | integer | The max time in seconds, after which the single BULK Job should be CANCELED and retried. The bigger the value the longer the BULK Job is allowed to run. |
7 actions
Read live records straight from the Shopify API.
Fetch a single record by ID.
Write a new record back into Shopify.
Patch fields on an existing record.
Remove a record.
Query synced data with filters and sorting, with no API rate limits.
Natural-language search across synced Shopify records.
Full parameter-level details live in the Shopify entity reference.
Hybrid deployment
The data plane runs in your environment. Records, credentials and keys stay with you; the control plane only receives configuration and job metadata.
Your environment
Airbyte control plane
Use cases
List all customers in my Shopify store
Show me details for a recent customer
What products do I have in my store?
List all locations for my store
Show me inventory levels for a recent location
Show me all draft orders
List all custom collections in my store
Show me details for a recent order
Show me product variants for a recent product
Create a new customer in Shopify with email test@example.com
Update a customer's first name
Create a new product called 'Summer T-Shirt'
Update a product title
Create a draft order for a customer
Complete a draft order
Set inventory quantity for a product variant at a location
Create a basic discount code for 10% off
Set a metafield on a product
Create a new page on my store
Create a new blog post
Show me orders from the last 30 days
Show me abandoned checkouts from this week
What price rules are currently active?
Show me all pages on my store
List all blog articles
Are there any open disputes?
FAQ
No. One Shopify authorization powers both the scheduled syncs that land data in your destination and the entity actions your agents call at runtime.
No. Entity actions read and write through the Shopify API as they are called, so they work immediately. Context store search is the exception: it queries data Airbyte has already synced, which is what lets it filter and sort without spending API rate limits.
38 streams, including Abandoned Checkouts, Articles, Balance Transactions, Blogs, Collects, Collection Products (GraphQL), Collections (GraphQL), Countries (GraphQL) and more.
Yes. The Shopify connector supports incremental sync on selected streams, and full refresh on every stream.
Run the Shopify connector on Cloud, OSS, Hybrid. Hybrid deployments keep the data plane in your environment while the control plane orchestrates syncs.
Didn't find your answer? Talk to sales
Free 14-day trial. One connection powers your scheduled syncs and your live Shopify actions.