How can I group multiple webhook meeting transcripts by title and send them to a Python API in n8n?

A ideia é criar um fluxo que aguarde os dados dos três tipos de reunião, agrupe as transcrições por título e envie o conjunto para sua API. A seguir, uma proposta de como estruturar o fluxo:

---

1. Recepção dos Webhooks

• Crie três nós Webhook – um para cada tipo de reunião (por exemplo, "reunião A", "reunião B" e "reunião C").
• Em cada nó, extraia as informações importantes, como o título da reunião e a transcrição.

---

2. Agrupamento dos Eventos

Como os webhooks podem chegar em momentos diferentes e várias reuniões podem ocorrer, você precisará agrupar os dados pelo título da reunião.

Uma abordagem é:

• Armazenamento Temporário:
  Utilize um nó [Function] para armazenar os eventos recebidos em uma variável de fluxo (workflow static data) ou, se necessário, em um banco de dados externo (por exemplo, usando um nó de banco de dados). Assim, cada vez que um webhook chegar, você pode:
  • Ler o armazenamento existente.
  • Verificar se já existe um agrupamento para aquele título.
  • Acrescentar a nova transcrição àquele grupo.
• Merge dos Dados:
  Outra opção é utilizar um nó Merge em modo “Wait” ou “Combine” para unificar os dados dos três webhooks – isso é útil caso você saiba que as três chamadas poderão ser recebidas dentro de um intervalo de tempo controlado. Por exemplo, configure o Merge node para aguardar os três inputs antes de seguir.

---

3. Processamento e Envio para a API Python

Depois de ter os dados agrupados (por reunião ou por título), adicione um nó Function para transformar os dados no formato desejado pela sua API.

Exemplo de código para o node Function (ajuste conforme a estrutura dos dados dos seus webhooks):

JAVASCRIPTCopied
// Supondo que cada item tenha: { meetingTitle, transcription, type }  
// e que os dados agrupados estão em `items`

const grouped = {};

for (const item of items) {
  const { meetingTitle, transcription, type } = item.json;
  
  if (!grouped[meetingTitle]) {
    grouped[meetingTitle] = { meetingTitle, transcriptions: {} };
  }
  
  // Pode ser que você precise agrupar por tipo também
  if (!grouped[meetingTitle].transcriptions[type]) {
    grouped[meetingTitle].transcriptions[type] = [];
  }
  
  grouped[meetingTitle].transcriptions[type].push(transcription);
}

// Converter o objeto para um array, se necessário:
const output = [];
for (const title in grouped) {
  output.push(grouped[title]);
}

return [{ json: { report: output } }];

Em seguida, use um nó HTTP Request para enviar os dados agrupados para sua API Python:

• Configure o método (por exemplo, POST).
• Na URL, informe o endpoint da sua API.
• No corpo da requisição, mapeie o resultado do agrupamento.

Exemplo de configuração do HTTP Request:

JSONCopied
{
  "url": "https://sua-api.com/endpoint",
  "method": "POST",
  "json": true,
  "body": "={{$json.report}}"
}

---

4. Considerações

• Sincronização:
  Se os webhooks podem chegar em momentos muito distantes, você pode precisar de uma estratégia para “fechar” um agrupamento (por exemplo, utilizando um nó Wait ou um timer) e enviar os dados assim que todos os inputs esperados forem recebidos ou após um tempo limite.

• Persistência:
  Caso o agrupamento se dê através de múltiplas execuções da workflow, considere usar dados estáticos do workflow (workflow static data) ou um serviço externo para armazenar os dados temporariamente até que o agrupamento esteja completo.

• Validação:
  Certifique-se de validar os dados e tratar possíveis problemas (como dados incompletos) antes de enviar para a API.

---

Essa é uma estratégia para criar seu fluxo no n8n. Você pode adaptar conforme a complexidade dos seus inputs e o comportamento esperado dos webhooks. Se precisar de mais detalhes ou ajustes, estou à disposição para ajudar!