Sync Shopify Products to Airtable

When a product is updated in Shopify (any field changes including title, description, price, inventory, variants, images, or tags), this trigger activates the workflow and captures complete product data including {{shopify.id}}, {{shopify.title}}, {{shopify.image.src}}, and all product properties. The workflow runs for every product update in your store.

This step lists all records from the "Products" table in your Airtable base. Setup requirement: You need an Airtable base with two tables: "Products" and "Variants". The template provides a pre-configured Airtable base you can copy—click the Airtable template link, make a copy to your workspace, then select that copied base in the workflow configuration. The Products table should have columns for Product ID, Title, and Images. The Variants table should have columns for Variant ID, SKU, Title, Product (linked record to Products table), Price, and Compare At.

This transform step creates a mapping object with three fields: "Product ID" ({{shopify.id}}), "Title" ({{shopify.title}}), and "Images" ({{shopify.image.src}}). This structured data is passed to the next step for upserting to Airtable. The transform ensures data is in the exact format Airtable expects for record creation or updates.

This custom code step implements an "upsert" operation (update if exists, insert if new) for the Products table. It uses the table_name "Products", field_name "Product ID", and field_value {{shopify.id}} to search Airtable for an existing record.

If a record with this Product ID exists, it updates that record with the current product data from the transform step.

If no record exists, it creates a new one. The code returns the Airtable record (including its Airtable record ID as {{airtable_product_upsert.id}}) which is needed to link variants to this product in subsequent steps.

Upsert logic (from airtable_product_upsert.js):

1. Search Airtable for record where Product ID matches {{shopify.id}}
2. If found: Update existing record with current product fields
3. If not found: Create new record with product fields
4. Return the Airtable record with its ID

This step retrieves all variants for the product using {{shopify.id}} as the product identifier. It returns an array of variants as {{shopify_1}} with each variant containing properties like {{variant.id}}, {{variant.sku}}, {{variant.title}}, {{variant.price}}, and {{variant.compare_at_price}}. This comprehensive variant data enables the workflow to sync all variant details to Airtable.

This loop step iterates through each variant in the {{shopify_1}} array. For every variant, the loop executes the subsequent transform and upsert steps using {{loop.id}}, {{loop.sku}}, {{loop.title}}, {{loop.price}}, and {{loop.compare_at_price}}. This enables variant-level tracking and reporting in Airtable.

This transform step creates a mapping object with six fields: "SKU" ({{loop.sku}}), "Title" ({{loop.title}}), "Variant ID" ({{loop.id}}), "Product" ({{airtable_product_upsert.id}}), "Price" ({{loop.price}}), and "Compare At" ({{loop.compare_at_price}}). The "Product" field uses the Airtable record ID from step 4, creating a linked record relationship between the Variants table and Products table. This enables Airtable views and filters that show which variants belong to which products.

This custom code step implements an "upsert" operation for the Variants table. It uses table_name "Variants", field_name "Variant ID", and field_value {{loop.id}} to search for an existing variant record.

If found, it updates with current variant data from the transform step.

If not found, it creates a new variant record. The Product field (containing {{airtable_product_upsert.id}}) links the variant to its parent product in Airtable.

Upsert logic (from airtable_variant_upsert.js):

1. Search Airtable for record where Variant ID matches {{loop.id}}
2. If found: Update existing record with current variant fields
3. If not found: Create new record with variant fields (including product link)
4. Return the updated/created Airtable record