This workflow follows the HTTP Request → HubSpot recipe pattern — see all workflows that pair these two integrations.
The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"nodes": [
{
"id": "9be821db-fbc7-4168-962f-26c8382cefbf",
"name": "If charge has customer",
"type": "n8n-nodes-base.if",
"position": [
1560,
880
],
"parameters": {
"conditions": {
"string": [
{
"value1": "={{ $json[\"customer\"] }}",
"operation": "isNotEmpty"
}
]
}
},
"typeVersion": 1
},
{
"id": "d06bae31-6856-4941-b86c-c611fc9d3da6",
"name": "Get customer",
"type": "n8n-nodes-base.stripe",
"position": [
2160,
920
],
"parameters": {
"resource": "customer",
"customerId": "={{ $json[\"customer\"] }}"
},
"credentials": {
"stripeApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "4e0d87bf-084f-4958-b2d3-cf7985f8c901",
"name": "On schedule",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
-400,
1400
],
"parameters": {
"rule": {
"interval": [
{}
]
}
},
"typeVersion": 1
},
{
"id": "fb620c92-5e22-4a9c-9320-847442b5e955",
"name": "Remove duplicate customers",
"type": "n8n-nodes-base.itemLists",
"position": [
1880,
920
],
"parameters": {
"compare": "selectedFields",
"options": {
"removeOtherFields": true
},
"operation": "removeDuplicates",
"fieldsToCompare": {
"fields": [
{
"fieldName": "customer"
}
]
}
},
"typeVersion": 1
},
{
"id": "3ad7554d-24b3-4ee2-8136-6a151bf06c71",
"name": "Aggregate `amount_captured`",
"type": "n8n-nodes-base.itemLists",
"position": [
1880,
540
],
"parameters": {
"options": {},
"operation": "aggregateItems",
"fieldsToAggregate": {
"fieldToAggregate": [
{
"fieldToAggregate": "amount_captured"
}
]
}
},
"typeVersion": 1
},
{
"id": "c8448580-40f2-4cf6-87ba-80903555d5a5",
"name": "Aggregate totals",
"type": "n8n-nodes-base.code",
"position": [
2820,
1360
],
"parameters": {
"jsCode": "// aggregate `amounts_captured` with the customer, taking note \n// that `aggregateAmountsPerContact` is the value in cents\nconst aggregateAmountsPerContact = new Object();\nfor (const item of $input.all()) {\n if (aggregateAmountsPerContact[item.json.email] == null) {\n aggregateAmountsPerContact[item.json.email] = 0;\n }\n aggregateAmountsPerContact[item.json.email] += item.json.amount_captured;\n}\n\n// parse the data in a way that is usable in future nodes, and\n// converts amounts from cents to dollars\nconst parsed = [];\nfor (const contact of Object.keys(aggregateAmountsPerContact)) {\n parsed.push({\n email: contact,\n amount_captured: aggregateAmountsPerContact[contact] / 100\n });\n}\n\nreturn parsed;"
},
"typeVersion": 1
},
{
"id": "dedaf89e-84d1-4964-9c87-94beea4adf26",
"name": "Create or update customer",
"type": "n8n-nodes-base.hubspot",
"position": [
3140,
1360
],
"parameters": {
"email": "={{$node[\"Aggregate totals\"].json[\"email\"]}}",
"resource": "contact",
"authentication": "oAuth2",
"additionalFields": {
"customPropertiesUi": {
"customPropertiesValues": [
{
"value": "={{$node[\"Aggregate totals\"].json[\"amount_captured\"]}}",
"property": "={{$(\"Configure\").first().json[\"contactPropertyId\"]}}"
}
]
}
}
},
"credentials": {
"hubspotOAuth2Api": {
"name": "<your credential>"
}
},
"notesInFlow": false,
"typeVersion": 1
},
{
"id": "4c419e90-facc-4a64-83f2-d349264338c6",
"name": "Merge data",
"type": "n8n-nodes-base.merge",
"position": [
2520,
1360
],
"parameters": {
"mode": "combine",
"options": {},
"mergeByFields": {
"values": [
{
"field1": "id",
"field2": "customer"
}
]
}
},
"typeVersion": 2
},
{
"id": "6a21495f-e567-4b0f-b584-34306bf7fa18",
"name": "Note",
"type": "n8n-nodes-base.stickyNote",
"position": [
2460,
1160
],
"parameters": {
"width": 219.61431588546765,
"height": 378.32426823578305,
"content": "### `Merge data`\nMore specifically, we merge the Stripe data from `Get charges` and `Get customer` nodes. Only the charges with customers on them will continue."
},
"typeVersion": 1
},
{
"id": "7319c8fe-9e55-43d9-a634-3a7884268016",
"name": "Note1",
"type": "n8n-nodes-base.stickyNote",
"position": [
2760,
1160
],
"parameters": {
"width": 218.46574043407196,
"height": 379.1631729345614,
"content": "### `Aggregate totals`\nGiven the merged data, we now aggregate the amounts from charges to the customers/contacts."
},
"typeVersion": 1
},
{
"id": "c24d972b-270d-4467-9352-4ced18e377c0",
"name": "Note2",
"type": "n8n-nodes-base.stickyNote",
"position": [
1780,
400
],
"parameters": {
"width": 297.57428772569784,
"height": 325.06310253513686,
"content": "### ``Aggregate `amount_captured` ``\nThis does nothing. It is an alternative way to find the totals of every charge in existence in Stripe. Potentially useful for debugging purposes."
},
"typeVersion": 1
},
{
"id": "43da8885-fac3-4cb7-9f01-c4770cd0b030",
"name": "Get all charges",
"type": "n8n-nodes-base.stripe",
"position": [
1300,
1380
],
"parameters": {
"resource": "charge",
"operation": "getAll",
"returnAll": true
},
"credentials": {
"stripeApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "abfe75f5-c36f-4904-a703-cb8d1d83b686",
"name": "Note3",
"type": "n8n-nodes-base.stickyNote",
"position": [
-960,
1220
],
"parameters": {
"width": 504,
"height": 510.0404950205649,
"content": "## Sync Stripe charges to HubSpot contacts\nThis workflow pushes Stripe charges to HubSpot contacts. It uses the Stripe API to get all charges and the HubSpot API to update the contacts. The workflow will create a new HubSpot property to store the total amount charged. If the property already exists, it will update the property.\n\n### How it works\n1. On a schedule, the first Stripe node gets all charges. The default schedule is once a day at midnight.\n2. Once the charges are returned, the second Stripe node gets extra customer information.\n3. Once the customer information is returned, `Merge data` node will merge the customer information with the charges so that the next node `Aggregate totals` can calculate the total amount charged per contact.\n4. Once we have the total amount charged per contact, the `Create or update customer` node will create a new HubSpot property to store the total amount charged. If the property already exists, it will update the property.\n\n\n\nWorkflow written by [David Sha](https://davidsha.me)."
},
"typeVersion": 1
},
{
"id": "67e44a47-18db-48a3-a08e-c4f2afb13a30",
"name": "Note4",
"type": "n8n-nodes-base.stickyNote",
"position": [
1780,
760
],
"parameters": {
"width": 298.2919335506821,
"height": 339.6783118583311,
"content": "### `Remove duplicate customers`\nEnsures that we do not poll Stripe too many times unnecessarily. If multiple charges have the same customer, we ensure that we do not ask for the same information again."
},
"typeVersion": 1
},
{
"id": "02d46492-f3ba-47fe-ba88-f2baad30fc73",
"name": "Get HubSpot field",
"type": "n8n-nodes-base.httpRequest",
"position": [
580,
1540
],
"parameters": {
"url": "=https://api.hubapi.com/crm/v3/properties/contact/{{$(\"Configure\").first().json[\"contactPropertyId\"]}}",
"options": {},
"authentication": "predefinedCredentialType",
"nodeCredentialType": "hubspotOAuth2Api"
},
"credentials": {
"hubspotOAuth2Api": {
"name": "<your credential>"
}
},
"typeVersion": 3,
"continueOnFail": true
},
{
"id": "827882c4-5d3f-4cc6-b876-ae575a9a1b36",
"name": "Create field in HubSpot",
"type": "n8n-nodes-base.httpRequest",
"position": [
980,
1660
],
"parameters": {
"url": "https://api.hubapi.com/crm/v3/properties/contact",
"method": "POST",
"options": {
"response": {
"response": {
"neverError": true
}
}
},
"sendBody": true,
"authentication": "predefinedCredentialType",
"bodyParameters": {
"parameters": [
{
"name": "name",
"value": "={{$(\"Configure\").first().json[\"contactPropertyId\"]}}"
},
{
"name": "label",
"value": "={{$(\"Configure\").first().json[\"contactPropertyLabelName\"]}}"
},
{
"name": "type",
"value": "number"
},
{
"name": "fieldType",
"value": "number"
},
{
"name": "groupName",
"value": "contactinformation"
},
{
"name": "formField",
"value": "false"
},
{
"name": "description",
"value": "=The total spend determined by the charges in Stripe. This is a field required for \"{{$workflow.name}}\" n8n workflow."
}
]
},
"nodeCredentialType": "hubspotOAuth2Api"
},
"credentials": {
"hubspotOAuth2Api": {
"name": "<your credential>"
}
},
"typeVersion": 3
},
{
"id": "b4092718-bf35-49b5-aefa-b9900596fcb5",
"name": "Note5",
"type": "n8n-nodes-base.stickyNote",
"position": [
500,
1480
],
"parameters": {
"width": 656.5118956254801,
"height": 367.20468504951214,
"content": "### Create HubSpot field if required\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n_These nodes create a HubSpot field if required.\nIt makes the contact field that this workflow uses \nto store the Stripe information. To disable this \nsection, in `Configure` node change `checkFields`\nto false._"
},
"typeVersion": 1
},
{
"id": "6d74e2e3-bd95-4ccb-89c0-3d6f8f1e01f9",
"name": "Configure",
"type": "n8n-nodes-base.set",
"position": [
-80,
1400
],
"parameters": {
"values": {
"string": [
{
"name": "contactPropertyId",
"value": "stripe___total_spend"
},
{
"name": "contactPropertyLabelName",
"value": "Stripe - Total Spend"
}
],
"boolean": [
{
"name": "checkFields",
"value": true
}
]
},
"options": {}
},
"typeVersion": 1
},
{
"id": "8a8262bc-0742-4529-9f10-328c338854fe",
"name": "Note6",
"type": "n8n-nodes-base.stickyNote",
"position": [
-200,
1340
],
"parameters": {
"width": 338.8262165118159,
"height": 505.43603897947025,
"content": "### Configuration\n\n\n\n\n\n\n\n\n\n\n\n\nBy default, this does not need to be updated. \n\n__`contactPropertyId` (required)__: Only change if the specific HubSpot field ID has been taken.\n\n__`contactPropertyLabelName` (required)__: Change if you would like a different display name.\n\n__`checkFields` (required)__: Turn to false if you would like to optimise this workflow, provided this workflow has run once before with this configurable enabled. This will disable the section of this workflow which deals with creating a HubSpot field."
},
"typeVersion": 1
},
{
"id": "fc640a31-2050-4276-a1f7-8154f61d2729",
"name": "Note7",
"type": "n8n-nodes-base.stickyNote",
"position": [
3080,
1160
],
"parameters": {
"width": 219.86482940052417,
"height": 377.58888520886353,
"content": "### `Create or update customer`\nBy default, the only field updated is \"Stripe - Total Spend\". The contact is identified by its email."
},
"typeVersion": 1
},
{
"id": "c91295e6-0306-4f3d-adcf-923fbef1c173",
"name": "Skip field checking",
"type": "n8n-nodes-base.if",
"position": [
240,
1400
],
"parameters": {
"conditions": {
"boolean": [
{
"value1": "={{$node[\"Configure\"].json[\"checkFields\"]}}",
"value2": "={{false}}"
}
]
}
},
"typeVersion": 1
},
{
"id": "8f8b5a15-4895-4c5a-b8ba-8592dd754aca",
"name": "Do nothing",
"type": "n8n-nodes-base.noOp",
"position": [
1880,
1240
],
"parameters": {},
"typeVersion": 1
},
{
"id": "b953e439-955c-4046-9000-32cbb3577c27",
"name": "Note8",
"type": "n8n-nodes-base.stickyNote",
"position": [
1780,
1140
],
"parameters": {
"width": 298.2919335506821,
"height": 247.94509463108915,
"content": "### `Do nothing`\nThis is useful to know what Stripe charges had no customer assigned."
},
"typeVersion": 1
},
{
"id": "ec2116e5-2a4a-4edf-a816-b15c349f23e0",
"name": "If field exists",
"type": "n8n-nodes-base.if",
"position": [
780,
1540
],
"parameters": {
"conditions": {
"number": [
{
"value1": "={{ $json[\"error\"][\"httpCode\"] }}",
"value2": "404",
"operation": "notEqual"
}
]
}
},
"typeVersion": 1
}
],
"connections": {
"Configure": {
"main": [
[
{
"node": "Skip field checking",
"type": "main",
"index": 0
}
]
]
},
"Merge data": {
"main": [
[
{
"node": "Aggregate totals",
"type": "main",
"index": 0
}
]
]
},
"On schedule": {
"main": [
[
{
"node": "Configure",
"type": "main",
"index": 0
}
]
]
},
"Get customer": {
"main": [
[
{
"node": "Merge data",
"type": "main",
"index": 0
}
]
]
},
"Get all charges": {
"main": [
[
{
"node": "If charge has customer",
"type": "main",
"index": 0
},
{
"node": "Merge data",
"type": "main",
"index": 1
}
]
]
},
"If field exists": {
"main": [
[
{
"node": "Get all charges",
"type": "main",
"index": 0
}
],
[
{
"node": "Create field in HubSpot",
"type": "main",
"index": 0
}
]
]
},
"Aggregate totals": {
"main": [
[
{
"node": "Create or update customer",
"type": "main",
"index": 0
}
]
]
},
"Get HubSpot field": {
"main": [
[
{
"node": "If field exists",
"type": "main",
"index": 0
}
]
]
},
"Skip field checking": {
"main": [
[
{
"node": "Get all charges",
"type": "main",
"index": 0
}
],
[
{
"node": "Get HubSpot field",
"type": "main",
"index": 0
}
]
]
},
"If charge has customer": {
"main": [
[
{
"node": "Remove duplicate customers",
"type": "main",
"index": 0
},
{
"node": "Aggregate `amount_captured`",
"type": "main",
"index": 0
}
],
[
{
"node": "Do nothing",
"type": "main",
"index": 0
}
]
]
},
"Create field in HubSpot": {
"main": [
[
{
"node": "Get all charges",
"type": "main",
"index": 0
}
]
]
},
"Remove duplicate customers": {
"main": [
[
{
"node": "Get customer",
"type": "main",
"index": 0
}
]
]
}
}
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
hubspotOAuth2ApistripeApi
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
How this works
This workflow automates the reconciliation of Stripe payment data with HubSpot customer records on a scheduled basis, ensuring your sales team always has up-to-date revenue insights without manual effort. It's ideal for e-commerce businesses or subscription services that rely on accurate financial tracking to inform customer interactions and reporting. The key step involves aggregating captured amounts from Stripe charges, removing duplicates, and merging this data to create or update corresponding HubSpot profiles seamlessly.
Use this workflow when you need daily or weekly syncs of payment totals to maintain clean CRM data, especially in growing teams handling recurring revenue. Avoid it for one-off reconciliations or if your volume exceeds thousands of transactions per run, as it could strain resources—opt for batched processing instead. Common variations include adjusting the cron schedule for monthly reports or adding filters to focus on specific customer segments.
About this workflow
Code Schedule. Uses stripe, scheduleTrigger, itemLists, hubspot. Scheduled trigger; 24 nodes.
Source: https://github.com/Zie619/n8n-workflows — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
Functionitem Pipedrive. Uses stripe, pipedrive, functionItem, itemLists. Scheduled trigger; 11 nodes.
Stripe, Pipedrive, Function Item +2
Http Stripe. Uses pipedriveTrigger, pipedrive, httpRequest, stripe. Event-driven trigger; 7 nodes.
Pipedrive Trigger, Pipedrive, HTTP Request +1
This workflow instantly sends successful Stripe Checkout payments to RD Station Marketing by creating an Order & Payment Event for every confirmed transaction. It’s ideal for businesses that want to a
Stripe Trigger, HTTP Request
Stripe Payment Order Sync – Auto Retrieve Customer & Product Purchased. Uses stripeTrigger, httpRequest. Event-driven trigger; 3 nodes.
Stripe Trigger, HTTP Request
This workflow automates inventory management and predictive reordering for Shopify stores. It integrates Shopify, Google Sheets, and Slack to monitor inventory levels, calculate dynamic reorder points
Shopify, Google Sheets, Gmail +2