Webhook Payload Router to Core API

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 →

{
  "name": "SMP - Factory Ingest Router",
  "nodes": [
    {
      "parameters": {
        "httpMethod": "POST",
        "path": "factory",
        "responseMode": "onReceived",
        "options": {}
      },
      "id": "3a3a3a3a-0003-0003-0003-000000000001",
      "name": "Webhook",
      "type": "n8n-nodes-base.webhook",
      "typeVersion": 1,
      "position": [
        250,
        300
      ]
    },
    {
      "parameters": {
        "jsCode": "const input = $input.first().json.body || $input.first().json;\nreturn [{\n  json: {\n    organizationId: input.organizationId || 'org_factory',\n    deviceId: input.deviceId || 'dev_fact_01',\n    domain: 'factory',\n    metrics: input.metrics || {},\n    timestamp: input.timestamp || Date.now()\n  }\n}];"
      },
      "id": "3a3a3a3a-0003-0003-0003-000000000002",
      "name": "Normalize Payload",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        500,
        300
      ]
    },
    {
      "parameters": {
        "method": "POST",
        "url": "http://host.docker.internal:3000/api/ingest",
        "sendBody": true,
        "specifyBody": "json",
        "jsonBody": "={{ JSON.stringify($json) }}",
        "options": {},
        "sendHeaders": true,
        "headerParameters": {
          "parameters": [
            {
              "name": "x-ingest-key",
              "value": "spla_ingest_dev_key"
            }
          ]
        }
      },
      "id": "3a3a3a3a-0003-0003-0003-000000000003",
      "name": "POST to Core",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4,
      "position": [
        760,
        300
      ]
    }
  ],
  "connections": {
    "Webhook": {
      "main": [
        [
          {
            "node": "Normalize Payload",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Normalize Payload": {
      "main": [
        [
          {
            "node": "POST to Core",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "settings": {
    "executionOrder": "v1"
  }
}

About this workflow

SMP - Factory Ingest Router. Uses httpRequest. Webhook trigger; 3 nodes.

Source: https://github.com/chi-cuongg/swd392/blob/d60f18b3b5bb3570fe435c3965ffaf4419420ba4/n8n/workflow-factory.json — original creator credit. Request a take-down →

More Web Scraping workflows → · Browse all categories →

Related workflows

Workflows that share integrations, category, or trigger type with this one. All free to copy and import.