Skip to content

GraphQL Import Pipeline

Full catalog cursor-based ingest from Shopify Admin GraphQL API

Outbound Queue API Credentials

Run Catalog Ingest

Executes a cursor-based GraphQL batch traversal pulling products, inventory items, and variants from Shopify into the local MySQL cache.

Automatic throttle monitoring inspects Shopify cost leaky-bucket headers during cursor iteration.

Pipeline Telemetry

  • Shopify API Version 2025-01
  • Pagination Batch Size 50 items / page
  • Collision Resolution Upsert on shopify_gid

GraphQL Query Inspector

query fetchProductsCatalog($first: Int!, $after: String) {
  products(first: $first, after: $after) {
    pageInfo {
      hasNextPage
      endCursor
    }
    edges {
      cursor
      node {
        id
        title
        handle
        vendor
        productType
        status
        descriptionHtml
        updatedAt
        variants(first: 50) {
          edges {
            node {
              id
              title
              sku
              barcode
              price
              compareAtPrice
              inventoryQuantity
              inventoryItem {
                id
              }
            }
          }
        }
      }
    }
  }
}