How to Sync Shopify Customers to HubSpot with Pipedream

pipedream.com > Workflows > New Workflow

Create a new Pipedream workflow

Go to pipedream.com and sign in. Click 'New Workflow' in the top-right corner of the dashboard. You'll land on the workflow builder canvas with an empty trigger slot at the top. Give the workflow a name — something like 'Shopify → HubSpot Customer Sync' — using the pencil icon at the top of the page so you can find it later.

1. 1Click 'New Workflow' in the top-right of the Pipedream dashboard
2. 2Click the pencil icon next to 'My Workflow' and rename it to 'Shopify → HubSpot Customer Sync'
3. 3Click 'Save' to confirm the name

Workflow Canvas > Add a trigger > Shopify > New Order (Instant)

Add a Shopify trigger for new orders

Click the 'Add a trigger' block. Search for 'Shopify' in the app search box and select it. From the list of available triggers, choose 'New Order (Instant)' — this fires via webhook the moment Shopify creates an order, not on a delay. Pipedream will ask you to connect your Shopify store; click 'Connect Shopify Account' and enter your store's myshopify.com subdomain.

1. 1Click the grey 'Add a trigger' block on the canvas
2. 2Type 'Shopify' in the search field and click the Shopify app icon
3. 3Select 'New Order (Instant)' from the trigger list
4. 4Click 'Connect Shopify Account' and enter your store subdomain (e.g. mystore.myshopify.com)
5. 5Click 'Save and continue'

Trigger Block > Generate Test Event

Test the trigger with a real Shopify order

Click 'Generate Test Event' at the bottom of the trigger configuration panel. Pipedream will pull in the most recent order from your Shopify store as sample data. If your store has no orders yet, place a test order using Shopify's built-in test payment gateway first. Confirm that the event payload in the right panel contains customer fields like email, first_name, last_name, and phone.

1. 1Click 'Generate Test Event' in the trigger configuration panel
2. 2Wait for Pipedream to fetch the most recent Shopify order
3. 3Expand the 'customer' object in the event payload on the right panel
4. 4Confirm you can see fields: email, first_name, last_name, phone, total_spent

Workflow Canvas > + > Run Node.js code

Add a Node.js code step to extract and clean customer data

Click the '+' button below the trigger block to add a step. Select 'Run Node.js code'. This step pulls the customer fields out of the Shopify order payload and normalizes them — lowercasing the email, combining address fields — so HubSpot receives clean data. Paste the code from the Pro Tip section below directly into the code editor. This runs before any HubSpot API call, so errors here won't create bad contacts.

1. 1Click the '+' icon below the trigger block
2. 2Select 'Run Node.js code' from the step options
3. 3Clear the default code in the editor
4. 4Paste the transformation code from the Pro Tip section
5. 5Click 'Test' to run the step against your test event

Paste this into the Node.js code step (Step 4) that sits between your Shopify trigger and the HubSpot Find Contact step. It extracts and normalizes the customer fields, handles guest checkouts gracefully, and exports a clean object that all downstream HubSpot steps can reference via steps.normalize_customer.$return_value.

// Step: normalize_customer
// Runs after Shopify 'New Order (Instant)' trigger
// Cleans and extracts customer data before HubSpot API calls

// Step: normalize_customer
// Runs after Shopify 'New Order (Instant)' trigger
// Cleans and extracts customer data before HubSpot API calls

export default defineComponent({
  async run({ steps, $ }) {
    const order = steps.trigger.event;
    const customer = order.customer;

    // Exit cleanly on guest checkouts — no customer record to sync
    if (!customer || !customer.email) {
      return $.flow.exit('Skipping: guest checkout with no customer record');
    }

    const address = customer.default_address || order.billing_address || {};

    // Normalize the data for HubSpot
    const normalized = {
      email: customer.email.toLowerCase().trim(),
      firstname: customer.first_name?.trim() || '',
      lastname: customer.last_name?.trim() || '',
      phone: customer.phone || address.phone || null,
      city: address.city || null,
      country: address.country_code || null,
      total_revenue: customer.total_spent || '0.00',
      shopify_customer_id: String(customer.id),
      shopify_orders_count: String(customer.orders_count || 1),
      shopify_last_order_date: order.created_at || new Date().toISOString(),
    };

    // Validate required fields before proceeding
    if (!normalized.email.includes('@')) {
      throw new Error(`Invalid email format: ${normalized.email}`);
    }

    console.log(`[Normalize] Customer ${normalized.email} | Orders: ${normalized.shopify_orders_count} | Spent: $${normalized.total_revenue}`);

    return normalized;
  }
});

Workflow Canvas > + > HubSpot > Find Contact

Add a HubSpot step to search for an existing contact

Click '+' below the code step. Search for 'HubSpot' and select it. Choose the action 'Search CRM' or specifically 'Find Contact'. Set the search property to 'email' and map the value to the email output from your previous code step using the data picker (click the '{' icon to browse available fields). This check prevents duplicate contacts from being created when the same customer places a second order.

1. 1Click the '+' icon below the Node.js code step
2. 2Search for 'HubSpot' and click the HubSpot app icon
3. 3Select 'Find Contact' from the action list
4. 4Connect your HubSpot account via 'Connect HubSpot Account'
5. 5Set Property Name to 'email' and click the '{' icon to map Property Value to steps.nodejs.$return_value.email

Workflow Canvas > + > Run Node.js code

Add a conditional branch to route new vs. existing contacts

Click '+' below the HubSpot search step. Select 'Filter' or use a second Node.js code step to check whether the previous step returned a contact ID. If a contact ID exists, the workflow should update that contact. If no ID exists, it should create a new one. Pipedream supports this with a simple if/else in a code step — check steps.find_contact.$return_value.id and set a variable like contactId and isExisting accordingly.

1. 1Click '+' below the Find Contact step
2. 2Select 'Run Node.js code'
3. 3Write a conditional that checks if steps.find_contact.$return_value?.id exists
4. 4Export contactId and isExisting as return values for the next step

Workflow Canvas > + > HubSpot > Create Contact

Add a HubSpot step to create a new contact

Click '+' and add another HubSpot step. Select 'Create Contact'. Map each property from your Node.js clean-data step: email → email, first_name → firstname, last_name → lastname, phone → phone, city → city, country → country_code. Use the '{' data picker to reference steps.nodejs.$return_value for each field. This step only needs to run when isExisting is false — you'll handle that with the condition check in the next step or via Pipedream's step-level configuration.

1. 1Click '+' and select HubSpot > Create Contact
2. 2Click '{' next to Email and select steps.nodejs.$return_value.email
3. 3Map firstname, lastname, phone, city, and country_code from the same source
4. 4Add a custom property 'shopify_customer_id' and map it to steps.trigger.event.customer.id
5. 5Click 'Test' to verify the contact is created in HubSpot sandbox

Workflow Canvas > + > HubSpot > Update Contact

Add a HubSpot step to update an existing contact

Click '+' after your create step and add another HubSpot action. Select 'Update Contact'. Set the Contact ID field to the contactId value exported from your conditional step. Map the same field set as the create step. This ensures that when a returning customer places a new order, their phone number, address, and any other updated details are written back to HubSpot immediately.

1. 1Click '+' and select HubSpot > Update Contact
2. 2Set Contact ID to steps.conditional.$return_value.contactId
3. 3Map firstname, lastname, phone, city, and country_code from steps.nodejs.$return_value
4. 4Add the field total_spent and map it to steps.trigger.event.customer.total_spent
5. 5Click 'Test' using a test event with an existing customer email

Workflow Canvas > + > Run Node.js code

Add a final code step to log the outcome

Add one more Node.js step at the end of the workflow. This step logs whether a contact was created or updated, the HubSpot contact ID, and the Shopify order ID. Use console.log() — Pipedream captures all logs under the 'Logs' tab for each workflow run. This makes debugging failed runs significantly faster because you can see exactly which Shopify order triggered what HubSpot action without digging through raw JSON.

1. 1Click '+' and select 'Run Node.js code'
2. 2Write a console.log statement outputting the Shopify order ID, HubSpot contact ID, and action taken (created vs updated)
3. 3Return a summary object with the same fields
4. 4Click 'Test' and open the 'Logs' tab to confirm the output appears

Paste this into the Node.js code step (Step 4) that sits between your Shopify trigger and the HubSpot Find Contact step. It extracts and normalizes the customer fields, handles guest checkouts gracefully, and exports a clean object that all downstream HubSpot steps can reference via steps.normalize_customer.$return_value.

// Step: normalize_customer
// Runs after Shopify 'New Order (Instant)' trigger
// Cleans and extracts customer data before HubSpot API calls

// Step: normalize_customer
// Runs after Shopify 'New Order (Instant)' trigger
// Cleans and extracts customer data before HubSpot API calls

export default defineComponent({
  async run({ steps, $ }) {
    const order = steps.trigger.event;
    const customer = order.customer;

    // Exit cleanly on guest checkouts — no customer record to sync
    if (!customer || !customer.email) {
      return $.flow.exit('Skipping: guest checkout with no customer record');
    }

    const address = customer.default_address || order.billing_address || {};

    // Normalize the data for HubSpot
    const normalized = {
      email: customer.email.toLowerCase().trim(),
      firstname: customer.first_name?.trim() || '',
      lastname: customer.last_name?.trim() || '',
      phone: customer.phone || address.phone || null,
      city: address.city || null,
      country: address.country_code || null,
      total_revenue: customer.total_spent || '0.00',
      shopify_customer_id: String(customer.id),
      shopify_orders_count: String(customer.orders_count || 1),
      shopify_last_order_date: order.created_at || new Date().toISOString(),
    };

    // Validate required fields before proceeding
    if (!normalized.email.includes('@')) {
      throw new Error(`Invalid email format: ${normalized.email}`);
    }

    console.log(`[Normalize] Customer ${normalized.email} | Orders: ${normalized.shopify_orders_count} | Spent: $${normalized.total_revenue}`);

    return normalized;
  }
});

Workflow Canvas > Deploy

Deploy the workflow and verify the live webhook

Click 'Deploy' in the top-right of the workflow canvas. Pipedream will activate the Shopify webhook and begin listening for real events. Place a real test order in your Shopify store (you can use a $0.01 product with a real payment method, then refund it). Within 30 seconds, check the workflow's 'Events' tab in Pipedream to confirm the run completed successfully. Then open HubSpot Contacts to verify the contact was created or updated with the correct data.

1. 1Click the blue 'Deploy' button in the top-right corner
2. 2Confirm the workflow status changes to 'Active' (green dot next to the workflow name)
3. 3Place a test order in Shopify
4. 4Open Pipedream > Workflows > [Your Workflow] > Events tab and confirm a successful run appears
5. 5Open HubSpot > Contacts and verify the contact record shows the correct Shopify data