Gerenciador de Tarefas Paralelas Assíncronas Usando Nós Wait - Fluxo de trabalho n8n

Usuários Avançados de n8n: Indivíduos que precisam gerenciar caminhos de execução complexos e não lineares.
Integradores de Sistemas: Desenvolvedores que executam processamento em lote ou tarefas de ETL que envolvem longos tempos de espera por sistemas externos.
Otimizadores de Desempenho: Aqueles que buscam melhorar o rendimento do seu fluxo de trabalho n8n executando sub-tarefas concorrentemente.
Especialistas em Automação n8n: Usuários explorando os recursos avançados do nó Wait do n8n e chamadas assíncronas.

Ao lidar com operações de longa duração — como processamento de vídeo, análise complexa de dados ou chamadas de API que exigem polling — um fluxo de trabalho n8n linear padrão pode ficar bloqueado, potencialmente expirando o tempo limite ou consumindo tempo excessivo de execução. Este fluxo de trabalho n8n especializado resolve isso utilizando um padrão assíncrono.

Este template robusto do n8n usa o nó Execute Workflow do n8n para gerar sub-tarefas paralelas (workers) e o poderoso nó Wait do n8n para pausar o orquestrador principal até que essas sub-tarefas sejam concluídas e notifiquem através de um webhook exclusivo. Isso permite que a execução principal aguarde de forma eficiente, gerenciando inúmeras threads paralelas, maximizando a utilização de recursos e prevenindo timeouts. Se você procura templates n8n confiáveis para automação de alto desempenho, este design assíncrono é crucial.

Este fluxo de trabalho n8n opera em dois modos distintos: o Orquestrador (Fluxo Principal) e o Worker (Sub-Fluxo), alavancando chamadas recursivas para a mesma definição de fluxo de trabalho do n8n.

Fluxo do Orquestrador (Iniciação e Coleta)

1. Gatilho Start do n8n: O processo começa com o gatilho manual Start do n8n.


2. Execução Paralela: O fluxo de trabalho n8n se ramifica imediatamente, usando dois nós Execute Workflow (Call 1 e Call 2). Crucialmente, o parâmetro waitForSubWorkflow é definido como false, tornando as chamadas não bloqueantes (assíncronas).


3. Passagem de Detalhes de Retomada: Cada chamada passa parâmetros específicos (wait duration e um sufixo de webhook exclusivo) para o worker. A URL do webhook é o resumeUrl da execução principal do n8n, permitindo que o worker retorne a chamada.


4. Aguardando Resultados: O fluxo de trabalho principal do n8n então atinge dois nós dedicados Wait do n8n (Wait for Webhook 1 e Wait for Webhook 2). A execução pausa indefinidamente (ou por um limite definido) até que os fluxos worker chamem com sucesso os endpoints de webhook respectivos (/call1 e /call2).


5. Mesclagem e Resumo: Assim que ambas as tarefas paralelas reportarem seus resultados, o nó Merge do n8n combina os payloads, e o nó Sum do n8n calcula o resultado total das operações paralelas.

Fluxo do Worker (Simulação de Tarefa e Relatório)

1. Gatilho do Worker: O sub-fluxo começa via o gatilho Call Entry Point do n8n (um Execute Workflow Trigger) quando chamado pelo Orquestrador.


2. Tarefa Longa Simulada: O nó Wait Seconds do n8n pausa o fluxo pela duração solicitada pelo Orquestrador (ex: 5 segundos para Call 1, 3 segundos para Call 2), simulando a tarefa de longa duração.


3. Relatório de Retorno: O nó Request Webhook do n8n usa a URL do webhook de entrada para enviar uma requisição HTTP de volta ao nó Wait do fluxo de trabalho principal do n8n. Esta chamada carrega o payload do resultado, sinalizando para o fluxo principal continuar.

Para implantar este template n8n e utilizar esta técnica de processamento paralelo, siga estes passos:

1. Importar: Copie os dados JSON fornecidos e importe-os diretamente para sua instância n8n através do menu 'New' > 'Import from JSON'. Esta única importação define a lógica do Orquestrador e do Worker.


2. Verificação de Autorreferência: Como este fluxo de trabalho n8n se chama recursivamente, certifique-se de que o parâmetro workflowId nos nós Execute Workflow Call 1 e Call 2 aponte para o ID do fluxo de trabalho recém-importado. Ele deve detectar a autorreferência automaticamente, mas verifique se a execução falhar.


3. Credenciais: Este n8n workflow específico usa nós n8n base (Manual Trigger, Wait, Execute Workflow, HTTP Request) e não requer credenciais externas.


4. Execução: Execute o gatilho manual Start do n8n. Observe como o fluxo se divide, executa as tarefas temporizadas assincronamente e, em seguida, aguarda os webhooks para retomar e finalizar a soma.

Start (n8n Trigger): Um gatilho Manual Trigger do n8n usado unicamente para iniciar o fluxo de trabalho principal orquestrador do n8n para fins de teste.
Call Entry Point (n8n Trigger): O Execute Workflow Trigger dedicado que lida com as chamadas recebidas do fluxo principal. Ele aceita os parâmetros wait (número) e webhook (string) necessários para a tarefa do worker.
Call 1 / Call 2 (Execute Workflow n8n node): Estes nós são cruciais para a paralelização. Eles chamam o mesmo fluxo de trabalho n8n (este template), mas são configurados com waitForSubWorkflow: false para garantir a execução assíncrona. Eles passam tempos de wait exclusivos e a URL completa do webhook de retomada.
Wait Seconds (Wait n8n node): Localizado no caminho do Worker, este nó n8n pausa a execução por um tempo dinâmico, definido pelo parâmetro de entrada ={{ $('Call Entry Point').item.json.wait }}.
Request Webhook (HTTP Request n8n node): O passo final do fluxo Worker. Ele requisita dinamicamente a resumeUrl (={{ $('Call Entry Point').item.json.webhook }}) fornecida pelo Orquestrador, carregando o payload do resultado para retomar o fluxo de trabalho principal do n8n.
Wait for Webhook 1 / Wait for Webhook 2 (Wait n8n node): Localizados no caminho do Orquestrador, estes nós interrompem a execução, aguardando especificamente por uma chamada de webhook correspondente (usando um sufixo como /call1 ou /call2) para entregar o resultado assíncrono antes que o fluxo de trabalho n8n possa continuar.

• Merge / Sum (n8n node): Nós de agregação padrão usados para combinar os resultados recebidos pelos nós Wait e calcular o total final, demonstrando a coleta de dados assíncrona bem-sucedida.