davidzollo opened a new issue, #11027:
URL: https://github.com/apache/seatunnel/issues/11027
### Search before asking
- [x] I searched the latest `upstream/dev` code and found no native Shopify
connector implementation or connector registration.
- [x] I searched existing pull requests and found no dedicated Shopify
connector PR.
- [x] I searched existing issues and found no dedicated Shopify connector
issue. Shopify is currently only listed as a Todo item in the new connector
umbrella tracker #10753.
### Description
Shopify is a widely used commerce platform for online stores, order
management, product catalogs, inventory, customers, fulfillment, and related
operational data.
Currently, Apache SeaTunnel does not provide a native Shopify Source
connector. Users who want to ingest Shopify data into warehouses, lakes, search
systems, or downstream analytics pipelines need to build custom API extraction
logic outside SeaTunnel.
This issue proposes adding a dedicated Shopify Source connector under
Connector-V2.
### Proposed scope
The first implementation can start as a focused batch source connector and
expand later if needed.
Suggested V1 capabilities:
- Read common Shopify resources such as orders, products, customers,
inventory items, variants, collections, and fulfillments.
- Support token-based authentication for Shopify Admin API access.
- Support configurable resource selection, for example a single resource or
a list of resources.
- Support pagination and rate-limit aware retry/backoff.
- Support incremental extraction where Shopify exposes stable update
timestamps or cursors.
- Map Shopify records into SeaTunnel rows with predictable schemas.
- Provide English and Chinese connector documentation with runnable examples.
- Add focused tests for option validation, pagination handling, error
handling, and response-to-row conversion.
### Example direction
```hocon
source {
Shopify {
shop = "your-store.myshopify.com"
access_token = "${SHOPIFY_ACCESS_TOKEN}"
resources = [
{
table_path = "shopify.orders"
updated_at_min = "2026-01-01T00:00:00Z"
},
{
table_path = "shopify.products"
},
{
table_path = "shopify.customers"
}
]
request_timeout_ms = 60000
page_size = 250
}
}
```
The exact option names and supported resource list should be aligned with
SeaTunnel connector conventions during implementation review.
### Related issues
- #10753 tracks new connector claims and currently lists `Source | Shopify |
Todo | This issue`.
- No dedicated Shopify connector issue or PR was found when checking
`apache/seatunnel` on 2026-06-09.
### Are you willing to submit a PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's [Code of
Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
