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 →

Download .json

{
  "name": "Cleaner and Merger",
  "nodes": [
    {
      "parameters": {
        "triggerOn": "folder",
        "path": "D:\\My_Projects\\Project_Amazon_Products_Analytics_Pipeline\\Raw_Data",
        "events": [
          "change",
          "add"
        ],
        "options": {}
      },
      "type": "n8n-nodes-base.localFileTrigger",
      "typeVersion": 1,
      "position": [
        0,
        0
      ],
      "id": "aa9d9139-631a-4aea-b69a-ae9985f16a5e",
      "name": "File_Trigger_"
    },
    {
      "parameters": {
        "command": "=python \"D:/My_Projects/Project_Amazon_Products_Analytics_Pipeline/n8n_Cleaners/n8n_merger.py\" \"D:/My_Projects/Project_Amazon_Products_Analytics_Pipeline/Clean_Data\" \"amazon_products\""
      },
      "type": "n8n-nodes-base.executeCommand",
      "typeVersion": 1,
      "position": [
        320,
        0
      ],
      "id": "986c7d40-7bb4-4ebf-81c1-9521f8266ccd",
      "name": "File_Merger"
    },
    {
      "parameters": {
        "command": "=python \"D:\\My_Projects\\Project_Amazon_Products_Analytics_Pipeline\\n8n_Cleaners\\n8n_cleaner.py\" \"{{ $json.path }}\" \"{{ $json.path.replace('Raw_Data', 'Clean_Data').replace(/[^\\\\]+$/, 'clean_' + $json.path.split('\\\\').pop()) }}\""
      },
      "type": "n8n-nodes-base.executeCommand",
      "typeVersion": 1,
      "position": [
        160,
        0
      ],
      "id": "45e3ec7d-f695-4983-85ae-7949b375ec16",
      "name": "Cleaner_File_1"
    }
  ],
  "connections": {
    "File_Trigger_": {
      "main": [
        [
          {
            "node": "Cleaner_File_1",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Cleaner_File_1": {
      "main": [
        [
          {
            "node": "File_Merger",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "active": false,
  "settings": {
    "executionOrder": "v1",
    "binaryMode": "separate",
    "availableInMCP": false
  },
  "versionId": "b8921a87-987d-40e8-b570-279b99f62657",
  "nodeGroups": [],
  "id": "ENFiAczJ1LrSzQma",
  "tags": []
}

Pro

For the full experience including quality scoring and batch install features for each workflow upgrade to Pro

About this workflow

Cleaner and Merger. Uses localFileTrigger, executeCommand. Event-driven trigger; 3 nodes.

Source: https://github.com/Amazingly12/Amazon-Products-Analytics-Pipeline/blob/main/Pipeline/n8n_workflow.json — original creator credit. Request a take-down →

More General workflows → · Browse all categories →

Related workflows

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

General

N8n Workflow

N8N Workflow. Uses executeCommand, localFileTrigger. Event-driven trigger; 7 nodes.

Execute Command, Local File Trigger

General

N8n Workflow (local File Trigger)

N8N Workflow. Uses localFileTrigger, executeCommand, readWriteFile. Event-driven trigger; 16 nodes.

Local File Trigger, Execute Command, Read Write File

General

Eco Gdrive Uploads V1

eco-gdrive-uploads-v1. Uses localFileTrigger, readBinaryFiles, googleDrive, executeCommand. Event-driven trigger; 5 nodes.

Local File Trigger, Read Binary Files, Google Drive +1

General

Executecommand Localfile

Executecommand Localfile. Uses localFileTrigger, executeCommand, lmChatMistralCloud, outputParserStructured. Event-driven trigger; 16 nodes.

Local File Trigger, Execute Command, Lm Chat Mistral Cloud +2

General

N8n Español - Ejemplos

N8N Español - Ejemplos. Uses manualTrigger, executeCommand. Event-driven trigger; 7 nodes.

Execute Command