Bring data from Shopify to your Lakehouse
https://[store].myshopify.com/admin
→ Store ID = [store]
.read_customers
read_inventory
read_locations
read_orders
read_products
Tip: The stream can be found more easily by typing its name.Select the streams and click Next.
Abandoned Checkouts
id
- Unique identifier for the abandoned checkoutabandonedCheckoutUrl
- URL for the abandoned checkoutcreatedAt
, updatedAt
, completedAt
- TimestampstaxesIncluded
- Whether taxes are includedsubtotalPriceSet.presentmentMoney.amount
, subtotalPriceSet.presentmentMoney.currencyCode
totalPriceSet.presentmentMoney.amount
, totalPriceSet.presentmentMoney.currencyCode
totalTaxSet.presentmentMoney.amount
, totalTaxSet.presentmentMoney.currencyCode
totalDiscountSet.presentmentMoney.amount
, totalDiscountSet.presentmentMoney.currencyCode
customer.id
, customer.firstName
, customer.lastName
, customer.email
customer.tags
, customer.state
, customer.note
customer.createdAt
, customer.updatedAt
billingAddress.*
- Address lines, city, province, country, zip, phoneshippingAddress.*
- Address lines, city, province, country, zip, phonelineItems[].id
, title
, sku
, quantity
lineItems[].variant.id
, lineItems[].variant.price
discountCodes[]
taxLines[].rate
, taxLines[].title
, taxLines[].priceSet.presentmentMoney.amount
, currencyCode
Collections
id
, title
, handle
, description
publishedAt
, updatedAt
image.altText
, image.originalSrc
products[].id
, title
, handle
, createdAt
, updatedAt
productType
, vendor
, tags
, totalInventory
, status
, price
, inventoryQuantity
variants[].id
, title
, sku
, price
, inventoryQuantity
sortOrder
, sortType
, sortValue
, templateSuffix
, url
metafields[].id
, namespace
, key
, value
, type
, description
Customers
id
, firstName
, lastName
createdAt
, updatedAt
verifiedEmail
, taxExempt
, tags
, state
numberOfOrders
amountSpent.amount
, amountSpent.currencyCode
defaultEmailAddress.emailAddress
, defaultEmailAddress.marketingState
defaultPhoneNumber.phoneNumber
, defaultPhoneNumber.marketingState
, defaultPhoneNumber.marketingCollectedFrom
addresses[].id
, firstName
, lastName
, address1
, city
, province
, country
, zip
, phone
, name
, provinceCode
, countryCodeV2
defaultAddress.*
- Same structure as addressesmetafields[].id
, namespace
, key
, value
, type
, description
Inventory Items
id
, legacyResourceId
, sku
, tracked
countryCodeOfOrigin
, provinceCodeOfOrigin
, harmonizedSystemCode
duplicateSkuCount
, inventoryHistoryUrl
countryHarmonizedSystemCodes[].countryCode
, harmonizedSystemCode
inventoryLevels[].id
inventoryLevels[].location.id
, inventoryLevels[].location.name
inventoryLevels[].item.id
, inventoryLevels[].item.sku
inventoryLevels[].quantities[].id
, name
, quantity
, updatedAt
locationsCount.count
measurement.weight.unit
, measurement.weight.value
unitCost.amount
, unitCost.currencyCode
variant.id
, variant.title
, variant.sku
variant.product.id
, variant.product.title
createdAt
, updatedAt
Locations
id
, name
, active
, activatable
, deactivatable
, deletable
createdAt
, updatedAt
, deactivatedAt
addressVerified
, isFulfillmentService
fulfillmentService.id
, fulfillmentService.serviceName
address.address1
, address.address2
, city
, country
, countryCode
, province
, provinceCode
, zip
metafields[].id
, namespace
, key
, value
, type
, description
Orders
id
, name
, legacyResourceId
, email
, phone
processedAt
, createdAt
, updatedAt
, cancelledAt
, closedAt
, confirmed
currencyCode
, presentmentCurrencyCode
transactions[].id
, kind
, status
, gateway
, authorizationCode
, test
, paymentId
, createdAt
, processedAt
transactions[].amountSet.presentmentMoney.amount
, currencyCode
transactions[].amountSet.shopMoney.amount
, currencyCode
transactions[].parentTransaction.id
totalPriceSet.shopMoney.amount
, currencyCode
totalPriceSet.presentmentMoney.amount
, currencyCode
subtotalPriceSet.*
, totalShippingPriceSet.*
, totalDiscountsSet.*
, totalTaxSet.*
(both shopMoney
and presentmentMoney
)totalWeight
, taxesIncluded
, taxExempt
displayFinancialStatus
, displayFulfillmentStatus
fullyPaid
, fulfillable
, restockable
, test
, customerAcceptsMarketing
sourceName
, sourceIdentifier
, currentSubtotalLineItemsQuantity
tags
, note
, clientIp
customer.id
, firstName
, lastName
, email
shippingAddress.*
, billingAddress.*
discountCode
, discountCodes[]
metafields[].id
, namespace
, key
, value
, type
, description
channelInformation.channelDefinition.handle
lineItems[].id
, title
, quantity
, sku
, vendor
, variantTitle
lineItems[].discountedTotalSet.*
, originalTotalSet.*
lineItems[].discountAllocations[].allocatedAmount.amount
, currencyCode
lineItems[].discountAllocations[].discountApplication.*
lineItems[].variant.id
, title
, sku
, product.id
, product.title
Products
id
, title
, descriptionHtml
, vendor
, productType
createdAt
, updatedAt
, publishedAt
, status
, tags
, templateSuffix
options[].id
, name
, position
, values[]
variants[].id
, title
, sku
, price
, position
, inventoryPolicy
, compareAtPrice
, createdAt
, updatedAt
, taxable
, barcode
variants[].inventoryItem.id
images[].id
, altText
, originalSrc
featuredImage.id
, featuredImage.altText
, featuredImage.originalSrc
metafields[].id
, namespace
, key
, value
, type
, description