AutomationFlowsWeb Scraping › Cnpj Flow

Cnpj Flow

cnpj_flow. Uses executeWorkflowTrigger, executeCommand, httpRequest. Event-driven trigger; 8 nodes.

Event trigger★★★★☆ complexity8 nodesExecute Workflow TriggerExecute CommandHTTP Request
Web Scraping Trigger: Event Nodes: 8 Complexity: ★★★★☆ Added:

This workflow follows the Executecommand → HTTP Request 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 →

Download .json
{
  "name": "cnpj_flow",
  "nodes": [
    {
      "parameters": {},
      "id": "e9c1db16-86eb-460d-9b5a-43eb25867f70",
      "name": "Execute Workflow Trigger",
      "type": "n8n-nodes-base.executeWorkflowTrigger",
      "typeVersion": 1,
      "position": [
        380,
        240
      ]
    },
    {
      "parameters": {
        "command": "=python3 /data/python/validate_cnpj.py \"{{ $json.cnpj }}\" || echo '{\"valid\": false, \"cnpj\": \"{{ $json.cnpj }}\", \"cleaned\": \"\"}'"
      },
      "id": "673f4c6e-821b-4fc6-b847-e1a5f57fbe13",
      "name": "Validate CNPJ (Python)",
      "type": "n8n-nodes-base.executeCommand",
      "typeVersion": 1,
      "position": [
        580,
        240
      ]
    },
    {
      "parameters": {
        "conditions": {
          "boolean": [
            {
              "value1": "={{ JSON.parse($json.stdout).valid }}",
              "value2": true
            }
          ]
        }
      },
      "id": "c1f71df0-562a-4a24-9b2f-3729e925bbf9",
      "name": "Is Valid?",
      "type": "n8n-nodes-base.if",
      "typeVersion": 1,
      "position": [
        780,
        240
      ]
    },
    {
      "parameters": {
        "url": "=https://brasilapi.com.br/api/cnpj/v1/{{ JSON.parse($json.stdout).cleaned }}",
        "options": {
          "redirect": {
            "redirect": {}
          }
        }
      },
      "id": "3af4757c-2bdf-4ea8-af82-b7e3240e8979",
      "name": "BrasilAPI CNPJ",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.1,
      "position": [
        980,
        140
      ],
      "onError": "continueRegularOutput",
      "retryOnFail": true,
      "maxTries": 3,
      "waitBetweenTries": 2000
    },
    {
      "parameters": {
        "conditions": {
          "string": [
            {
              "value1": "={{ $json.cnpj }}",
              "operation": "isNotEmpty"
            }
          ]
        }
      },
      "id": "5cb9fbba-d2f3-4f9b-a019-216174a7378c",
      "name": "Fetch Successful?",
      "type": "n8n-nodes-base.if",
      "typeVersion": 1,
      "position": [
        1180,
        140
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "status",
              "value": "success"
            },
            {
              "name": "cnpj",
              "value": "={{ $json.cnpj }}"
            },
            {
              "name": "razao_social",
              "value": "={{ $json.razao_social }}"
            },
            {
              "name": "situacao_cadastral",
              "value": "={{ $json.descricao_situacao_cadastral }}"
            },
            {
              "name": "cnae_codigo",
              "value": "={{ $json.cnae_fiscal }}"
            },
            {
              "name": "cnae_descricao",
              "value": "={{ $json.cnae_fiscal_descricao }}"
            },
            {
              "name": "data_abertura",
              "value": "={{ $json.data_inicio_atividade }}"
            },
            {
              "name": "logradouro",
              "value": "={{ $json.logradouro }}"
            },
            {
              "name": "numero",
              "value": "={{ $json.numero }}"
            },
            {
              "name": "complemento",
              "value": "={{ $json.complemento }}"
            },
            {
              "name": "bairro",
              "value": "={{ $json.bairro }}"
            },
            {
              "name": "uf",
              "value": "={{ $json.uf }}"
            },
            {
              "name": "municipio",
              "value": "={{ $json.municipio }}"
            },
            {
              "name": "cep",
              "value": "={{ $json.cep }}"
            }
          ]
        },
        "options": {}
      },
      "id": "f5f5cbe7-d16c-4b68-b7eb-304bb7f55b9e",
      "name": "Format Success Output",
      "type": "n8n-nodes-base.set",
      "typeVersion": 2,
      "position": [
        1380,
        80
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "status",
              "value": "error"
            },
            {
              "name": "cnpj",
              "value": "={{ $('Validate CNPJ (Python)').json.stdout ? JSON.parse($('Validate CNPJ (Python)').json.stdout).cnpj : '' }}"
            },
            {
              "name": "error_message",
              "value": "Empresa n\u00e3o encontrada ou falha de conex\u00e3o (404/Timeout)"
            }
          ]
        },
        "options": {}
      },
      "id": "1e66c79a-e279-4d69-a111-e6e22ee6919b",
      "name": "Format 404 Output",
      "type": "n8n-nodes-base.set",
      "typeVersion": 2,
      "position": [
        1380,
        220
      ]
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "status",
              "value": "error"
            },
            {
              "name": "cnpj",
              "value": "={{ $('Validate CNPJ (Python)').json.stdout ? JSON.parse($('Validate CNPJ (Python)').json.stdout).cnpj : '' }}"
            },
            {
              "name": "error_message",
              "value": "CNPJ inv\u00e1lido por d\u00edgito verificador"
            }
          ]
        },
        "options": {}
      },
      "id": "a9bfef61-e0e6-425f-bc9c-9dfd7ab3e1b1",
      "name": "Format Invalid Output",
      "type": "n8n-nodes-base.set",
      "typeVersion": 2,
      "position": [
        980,
        340
      ]
    }
  ],
  "connections": {
    "Execute Workflow Trigger": {
      "main": [
        [
          {
            "node": "Validate CNPJ (Python)",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Validate CNPJ (Python)": {
      "main": [
        [
          {
            "node": "Is Valid?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Is Valid?": {
      "main": [
        [
          {
            "node": "BrasilAPI CNPJ",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Format Invalid Output",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "BrasilAPI CNPJ": {
      "main": [
        [
          {
            "node": "Fetch Successful?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Fetch Successful?": {
      "main": [
        [
          {
            "node": "Format Success Output",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Format 404 Output",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "settings": {},
  "active": false
}
Pro

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

About this workflow

cnpj_flow. Uses executeWorkflowTrigger, executeCommand, httpRequest. Event-driven trigger; 8 nodes.

Source: https://github.com/alessandrogama/govdata-automator/blob/main/n8n/workflows/cnpj_flow.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.

Web Scraping

Backup Credentials to GitHub. Uses httpRequest, github, executeCommand, executeWorkflowTrigger. Event-driven trigger; 25 nodes.

HTTP Request, GitHub, Execute Command +1
Web Scraping

Based on Jonathan's work. Check out his templates.

HTTP Request, GitHub, Execute Command +1
Web Scraping

Backup your credentials to GitHub. Uses httpRequest, github, executeCommand, executeWorkflowTrigger. Event-driven trigger; 24 nodes.

HTTP Request, GitHub, Execute Command +1
Web Scraping

02_LLM_Pipeline v1.0. Uses executeWorkflowTrigger, httpRequest, seaTable. Event-driven trigger; 65 nodes.

Execute Workflow Trigger, HTTP Request, Sea Table
Web Scraping

This workflow allows you to import any workflow from a file or another n8n instance and map the credentials easily. A multi-form setup guides you through the entire process At the beginning you have t

Execute Command, Read Write File, HTTP Request +3