{ "edges": [ { "to": "a0608b0e-34fd-4da6-a8b5-1dbc04421679", "from": "feaa7db6-7908-4fb3-8628-30db47511c5e", "toPort": "0", "fromPort": "0" }, { "to": "6ebcade9-e215-4656-9fcd-360e1b5515c5", "from": "40847a27-4468-43c1-b603-670ba2590cc9", "toPort": "0", "fromPort": "0" }, { "to": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "from": "435a73e2-f90a-429d-984c-9db449e664c0", "toPort": "0", "fromPort": "0" }, { "to": "3334eff6-e5a6-4915-b95a-02258e507822", "from": "1930f36c-1b48-4938-8f5e-fe4547023825", "toPort": "0", "fromPort": "0" }, { "to": "31c7fa4e-fd95-467c-b6c6-b0280052be2c", "from": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "toPort": "0", "fromPort": "0" }, { "to": "40847a27-4468-43c1-b603-670ba2590cc9", "from": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "toPort": "0", "fromPort": "1" }, { "to": "feaa7db6-7908-4fb3-8628-30db47511c5e", "from": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "toPort": "0", "fromPort": "2" }, { "to": "44d39600-25f1-4359-914b-a3cf358da708", "from": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "toPort": "0", "fromPort": "3" }, { "to": "435a73e2-f90a-429d-984c-9db449e664c0", "from": "39ecbe50-5067-4092-a6ed-023ab45ca147", "toPort": "0", "fromPort": "0" }, { "to": "39ecbe50-5067-4092-a6ed-023ab45ca147", "from": "3334eff6-e5a6-4915-b95a-02258e507822", "toPort": "0", "fromPort": "0" }, { "to": "4aa05768-a3a3-460f-b5ea-d203bcd8af01", "from": "3334eff6-e5a6-4915-b95a-02258e507822", "toPort": "0", "fromPort": "1" }, { "to": "fe53a33d-c1ad-4bd3-a4b9-a90a7111882e", "from": "3334eff6-e5a6-4915-b95a-02258e507822", "toPort": "0", "fromPort": "1" }, { "to": "1930f36c-1b48-4938-8f5e-fe4547023825", "from": "acafb3fd-947c-4782-966e-ee185bffd5e9", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "3334eff6-e5a6-4915-b95a-02258e507822", "name": "Validate Required Fields1", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 3, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "id-1", "operator": { "type": "string", "operation": "exists" }, "leftValue": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.measurementId }}" }, { "id": "id-2", "operator": { "type": "string", "operation": "exists" }, "leftValue": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.timestamp }}" }, { "id": "id-3", "operator": { "type": "string", "operation": "exists" }, "leftValue": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.values }}" } ] } }, "position": [ -4560, -864 ] }, { "id": "39ecbe50-5067-4092-a6ed-023ab45ca147", "name": "Parse and Normalize Data1", "type": "set", "params": { "options": {}, "assignments": { "assignments": [ { "id": "id-1", "name": "measurementId", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.measurementId }}" }, { "id": "id-2", "name": "timestamp", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.timestamp }}" }, { "id": "id-3", "name": "deviceId", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.deviceId || 'unknown' }}" }, { "id": "id-4", "name": "operator", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.operator || 'N/A' }}" }, { "id": "id-5", "name": "partNumber", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.partNumber || 'N/A' }}" }, { "id": "id-6", "name": "dimension_x", "type": "number", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.values.x || 0 }}" }, { "id": "id-7", "name": "dimension_y", "type": "number", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.values.y || 0 }}" }, { "id": "id-8", "name": "dimension_z", "type": "number", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.values.z || 0 }}" }, { "id": "id-9", "name": "tolerance", "type": "number", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.values.tolerance || 0 }}" }, { "id": "id-10", "name": "status", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.status || 'received' }}" }, { "id": "id-11", "name": "notes", "type": "string", "value": "={{ $('Webhook Trigger - Receive Measurement Data').item.json.body.notes || '' }}" } ] } }, "position": [ -4240, -1184 ] }, { "id": "435a73e2-f90a-429d-984c-9db449e664c0", "name": "Send Success Response1", "type": "passthrough", "params": { "mode": "noOp", "options": { "responseCode": 200 }, "respondWith": "json", "responseBody": "={\n \"success\": true,\n \"message\": \"Measurement data received successfully\",\n \"measurementId\": \"{{ $json.measurementId }}\"\n}", "enableResponseOutput": true }, "position": [ -3968, -1184 ] }, { "id": "77cd0f46-66e8-4175-b2e1-10814a2d48cc", "name": "Route to Output Options1", "type": "switch", "params": { "rules": { "values": [ { "outputKey": "Google Sheets", "conditions": { "options": { "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "operator": { "type": "string", "operation": "equals" }, "leftValue": "={{ $('Workflow Configuration').item.json.outputMode }}", "rightValue": "sheets" } ] }, "renameOutput": true }, { "outputKey": "HTML Page", "conditions": { "options": { "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "operator": { "type": "string", "operation": "equals" }, "leftValue": "={{ $('Workflow Configuration').item.json.outputMode }}", "rightValue": "html" } ] }, "renameOutput": true }, { "outputKey": "CSV Email", "conditions": { "options": { "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "operator": { "type": "string", "operation": "equals" }, "leftValue": "={{ $('Workflow Configuration').item.json.outputMode }}", "rightValue": "csv" } ] }, "renameOutput": true }, { "outputKey": "Custom Code", "conditions": { "options": { "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "operator": { "type": "string", "operation": "equals" }, "leftValue": "={{ $('Workflow Configuration').item.json.outputMode }}", "rightValue": "custom" } ] }, "renameOutput": true } ] }, "options": {} }, "position": [ -3168, -1232 ] }, { "id": "31c7fa4e-fd95-467c-b6c6-b0280052be2c", "name": "Save to Google Sheets1", "type": "integration", "params": { "columns": { "value": { "notes": "={{ $json.notes }}", "status": "={{ $json.status }}", "deviceId": "={{ $json.deviceId }}", "operator": "={{ $json.operator }}", "timestamp": "={{ $json.timestamp }}", "tolerance": "={{ $json.tolerance }}", "partNumber": "={{ $json.partNumber }}", "dimension_x": "={{ $json.dimension_x }}", "dimension_y": "={{ $json.dimension_y }}", "dimension_z": "={{ $json.dimension_z }}", "measurementId": "={{ $json.measurementId }}" }, "schema": [ { "id": "measurementId", "required": false, "displayName": "measurementId", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "timestamp", "required": false, "displayName": "timestamp", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "deviceId", "required": false, "displayName": "deviceId", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "operator", "required": false, "displayName": "operator", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "partNumber", "required": false, "displayName": "partNumber", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "dimension_x", "required": false, "displayName": "dimension_x", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "dimension_y", "required": false, "displayName": "dimension_y", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "dimension_z", "required": false, "displayName": "dimension_z", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "tolerance", "required": false, "displayName": "tolerance", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "status", "required": false, "displayName": "status", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "notes", "required": false, "displayName": "notes", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "defineBelow", "matchingColumns": [ "measurementId" ] }, "options": { "useAppend": true }, "service": "googleSheets", "operation": "appendOrUpdate", "sheetName": { "__rl": true, "mode": "name", "value": "Measurements" }, "documentId": { "__rl": true, "mode": "id", "value": "={{ $('Workflow Configuration').item.json.googleSheetId }}" } }, "position": [ -2480, -2000 ] }, { "id": "40847a27-4468-43c1-b603-670ba2590cc9", "name": "Generate HTML Table1", "type": "passthrough", "params": { "html": "\n\n\n \n Measurement Data Report\n\n\n

Measurement Data Report

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Field	Value
Measurement ID	{{ $json.measurementId }}
Timestamp	{{ $json.timestamp }}
Device ID	{{ $json.deviceId }}
Operator	{{ $json.operator }}
Part Number	{{ $json.partNumber }}
Dimension X	{{ $json.dimension_x }}
Dimension Y	{{ $json.dimension_y }}
Dimension Z	{{ $json.dimension_z }}
Tolerance	{{ $json.tolerance }}
Status	{{ $json.status }}
Notes	{{ $json.notes }}

\n\n\n\n", "mode": "noOp" }, "position": [ -2464, -1488 ] }, { "id": "6ebcade9-e215-4656-9fcd-360e1b5515c5", "name": "Return HTML Page1", "type": "passthrough", "params": { "mode": "noOp", "options": { "responseCode": 200, "responseHeaders": { "entries": [ { "name": "Content-Type", "value": "text/html" } ] } }, "respondWith": "text", "responseBody": "={{ $json.html }}" }, "position": [ -2176, -1488 ] }, { "id": "feaa7db6-7908-4fb3-8628-30db47511c5e", "name": "Convert to CSV File1", "type": "passthrough", "params": { "mode": "noOp", "options": { "fileName": "={{ 'measurement-data-' + $now.format('yyyy-MM-dd-HHmmss') + '.csv' }}" } }, "position": [ -2464, -896 ] }, { "id": "a0608b0e-34fd-4da6-a8b5-1dbc04421679", "name": "Send Email with CSV1", "type": "integration", "params": { "text": "={{ 'Please find attached the measurement data export from ' + $('Parse and Normalize Data1').item.json.timestamp }}", "options": { "attachments": "data" }, "service": "smtp", "subject": "={{ $('Workflow Configuration').item.json.emailSubject }}", "toEmail": "={{ $('Workflow Configuration').item.json.emailRecipient }}", "fromEmail": "user@example.com", "operation": "read", "emailFormat": "text" }, "position": [ -2240, -896 ] }, { "id": "44d39600-25f1-4359-914b-a3cf358da708", "name": "Custom JavaScript Logic1", "type": "code", "params": { "jsCode": "// ============================================\n// CUSTOM JAVASCRIPT LOGIC FOR MEASUREMENT DATA\n// ============================================\n// This code demonstrates various ways to process measurement data:\n// 1. Access and transform the incoming data\n// 2. Send data to external APIs\n// 3. Store files in S3 (or other cloud storage)\n// 4. Trigger other n8n workflows\n// 5. Perform custom calculations and filtering\n\n// ============================================\n// 1. ACCESS INCOMING MEASUREMENT DATA\n// ============================================\n// Get all items from the previous node\nconst items = $input.all();\n\n// Access the first item's data\nconst firstItem = items[0].json;\nconsole.log('First measurement:', firstItem);\n\n// Example: Access specific fields from the measurement data\n// Assuming structure: { timestamp, sensorId, temperature, humidity, pressure }\nconst measurements = items.map(item => ({\n timestamp: item.json.timestamp,\n sensorId: item.json.sensorId,\n temperature: item.json.temperature,\n humidity: item.json.humidity,\n pressure: item.json.pressure\n}));\n\nconsole.log('Processed measurements:', measurements);\n\n// ============================================\n// 2. SEND DATA TO EXTERNAL API\n// ============================================\n// Example: Send measurement data to a custom API endpoint\nconst apiResults = [];\n\nfor (const measurement of measurements) {\n try {\n // Make HTTP request to external API\n const response = await $http.request({\n method: 'POST',\n url: 'https://api.example.com/measurements',\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': 'Bearer YOUR_TOKEN_HERE'\n },\n body: {\n sensor_id: measurement.sensorId,\n timestamp: measurement.timestamp,\n readings: {\n temperature: measurement.temperature,\n humidity: measurement.humidity,\n pressure: measurement.pressure\n }\n }\n });\n \n apiResults.push({\n success: true,\n sensorId: measurement.sensorId,\n apiResponse: response\n });\n } catch (error) {\n console.error('API Error:', error);\n apiResults.push({\n success: false,\n sensorId: measurement.sensorId,\n error: error.message\n });\n }\n}\n\n// ============================================\n// 3. STORE DATA IN AWS S3 (OR OTHER STORAGE)\n// ============================================\n// Example: Prepare data for S3 upload\nconst csvData = measurements.map(m => \n `${m.timestamp},${m.sensorId},${m.temperature},${m.humidity},${m.pressure}`\n).join('\\n');\n\nconst csvWithHeader = 'Timestamp,Sensor ID,Temperature,Humidity,Pressure\\n' + csvData;\n\n// Create a filename with current date\nconst filename = `measurements_${new Date().toISOString().split('T')[0]}.csv`;\n\n// Note: To actually upload to S3, you would use the AWS S3 node or make an API call\n// This example shows how to prepare the data\nconst s3Payload = {\n bucket: 'your-bucket-name',\n key: `measurements/${filename}`,\n content: csvWithHeader,\n contentType: 'text/csv'\n};\n\nconsole.log('S3 upload payload prepared:', s3Payload);\n\n// ============================================\n// 4. TRIGGER ANOTHER N8N WORKFLOW\n// ============================================\n// Example: Trigger another workflow via webhook\nconst workflowTriggerResults = [];\n\n// Only trigger if temperature exceeds threshold\nconst highTempMeasurements = measurements.filter(m => m.temperature > 30);\n\nif (highTempMeasurements.length > 0) {\n try {\n const triggerResponse = await $http.request({\n method: 'POST',\n url: 'https://avikadam.app.n8n.cloud/webhook/alert-workflow',\n headers: {\n 'Content-Type': 'application/json'\n },\n body: {\n alertType: 'HIGH_TEMPERATURE',\n measurements: highTempMeasurements,\n triggeredAt: new Date().toISOString()\n }\n });\n \n workflowTriggerResults.push({\n triggered: true,\n count: highTempMeasurements.length,\n response: triggerResponse\n });\n } catch (error) {\n console.error('Workflow trigger error:', error);\n workflowTriggerResults.push({\n triggered: false,\n error: error.message\n });\n }\n}\n\n// ============================================\n// 5. CUSTOM CALCULATIONS AND FILTERING\n// ============================================\n// Calculate statistics\nconst temperatures = measurements.map(m => m.temperature);\nconst avgTemp = temperatures.reduce((a, b) => a + b, 0) / temperatures.length;\nconst maxTemp = Math.max(...temperatures);\nconst minTemp = Math.min(...temperatures);\n\nconst statistics = {\n totalMeasurements: measurements.length,\n averageTemperature: avgTemp.toFixed(2),\n maxTemperature: maxTemp,\n minTemperature: minTemp,\n highTempAlerts: highTempMeasurements.length,\n processedAt: new Date().toISOString()\n};\n\nconsole.log('Statistics:', statistics);\n\n// ============================================\n// 6. RETURN PROCESSED DATA\n// ============================================\n// Return all processed data as output\nreturn [\n {\n json: {\n summary: statistics,\n measurements: measurements,\n apiResults: apiResults,\n s3Upload: s3Payload,\n workflowTriggers: workflowTriggerResults,\n processedCount: measurements.length\n }\n }\n];\n\n// ============================================\n// ADDITIONAL EXAMPLES\n// ============================================\n\n// Example: Group measurements by sensor ID\n// const groupedBySensor = measurements.reduce((acc, m) => {\n// if (!acc[m.sensorId]) acc[m.sensorId] = [];\n// acc[m.sensorId].push(m);\n// return acc;\n// }, {});\n\n// Example: Filter measurements by date range\n// const today = new Date().toISOString().split('T')[0];\n// const todayMeasurements = measurements.filter(m => \n// m.timestamp.startsWith(today)\n// );\n\n// Example: Transform data for specific database format\n// const dbRecords = measurements.map(m => ({\n// id: `${m.sensorId}_${m.timestamp}`,\n// sensor_id: m.sensorId,\n// measured_at: new Date(m.timestamp),\n// temp_celsius: m.temperature,\n// humidity_percent: m.humidity,\n// pressure_hpa: m.pressure,\n// created_at: new Date()\n// }));" }, "position": [ -2448, -416 ] }, { "id": "acafb3fd-947c-4782-966e-ee185bffd5e9", "name": "Webhook Trigger - Receive Measurement Data", "type": "trigger", "params": { "kind": "n8n-nodes-base.webhook", "path": "measurement-data", "options": {}, "httpMethod": "POST", "responseMode": "lastNode" }, "position": [ -5488, -864 ] }, { "id": "fe53a33d-c1ad-4bd3-a4b9-a90a7111882e", "name": "Send Error Response", "type": "passthrough", "params": { "mode": "noOp", "options": { "responseCode": 400 }, "respondWith": "json", "responseBody": "{\n \"success\": false,\n \"error\": \"Missing required fields: measurementId, timestamp, values\"\n}" }, "position": [ -4192, -368 ] }, { "id": "4aa05768-a3a3-460f-b5ea-d203bcd8af01", "name": "Error - Invalid Payload", "type": "passthrough", "params": { "mode": "noOp", "errorMessage": "Invalid payload: Missing required fields (measurementId, timestamp, values)" }, "position": [ -4192, -576 ] }, { "id": "1930f36c-1b48-4938-8f5e-fe4547023825", "name": "Workflow Configuration", "type": "set", "params": { "options": {}, "assignments": { "assignments": [ { "id": "id-1", "name": "outputMode", "type": "string", "value": "sheets" }, { "id": "id-2", "name": "googleSheetId", "type": "string", "value": "YOUR_SHEET_ID_HERE - Please replace with your actual Google Sheet ID" }, { "id": "id-3", "name": "emailRecipient", "type": "string", "value": "user@example.com" }, { "id": "id-4", "name": "emailSubject", "type": "string", "value": "Measurement Data Export" } ] }, "includeOtherFields": true }, "position": [ -4976, -864 ] } ] }

Route measurement data from a webhook to Google Sheets, email, or custom JS