Workflow n8n: Automatize Feeds RSS sobre qualquer assunto com IA

Como criar um workflow no n8n com loop e postagem automática no slack ou email.

A seguir, apresentamos um guia passo a passo para criar o fluxo de trabalho no n8n projetado para monitorar vários feeds RSS, filtrar novos artigos publicados na última hora, usar uma IA para verificar a relevância e, em seguida, postar um resumo a ser disparado em canal no Slack, por email etc.

Visão Geral do Fluxo de Trabalho

O fluxo de trabalho de exemplo opera da seguinte maneira:

• Agendamento: É executado a cada hora para verificar novos conteúdos.

• Fontes de notícias: Utiliza uma lista predefinida de URLs de feeds RSS focados no tema do seu projeto, exemplo: notícias de tecnologia.

• Filtro de tempo: Filtra apenas os artigos publicados na última hora para evitar duplicatas e conteúdo antigo.

• Processamento de IA: Cada artigo novo é enviado a um agente de IA (neste caso, um servidor local) para um resumo e para verificar se é relevante para o tema escolhido.

• Publicação: Se a IA considerar o artigo relevante, ele será postado em um canal específico do Slack.

Passo a Passo da Configuração

1. Configurar o Gatilho de Agendamento

O primeiro passo é definir a frequência com que o fluxo de trabalho será executado.

1. Adicione um nó Schedule Trigger.

2. Configure-o para ser executado a cada 1 hora. Isso garantirá que você receba as notícias mais recentes.

2. Definir a Lista de Feeds RSS

O próximo passo é criar uma lista dos feeds RSS que você deseja monitorar.

1. Adicione um nó Set e nomeie-o como List of RSS Feeds.

2. No campo Assignments, defina uma variável chamada urls.

3. O valor para urls deve ser um array JSON contendo as URLs dos feeds RSS. Insira a lista de urls no seguinte formato:

[["https://feeds2.feedburner.com/limontec","https://rss.tecmundo.com.br/feed"]]

3. Processar Feeds Individualmente

Para ler cada feed RSS da lista, é necessário dividir a lista em itens separados.

1. Conecte o nó List of RSS Feeds a um nó Split Out.

2. No nó Split Out, selecione o campo urls para dividir.

3. Conecte o nó Split Out a um nó RSS Feed Read.

4. No nó RSS Feed Read, no campo URL, use a expressão {{ $json.urls }} para que ele leia a URL de cada item que passa pelo fluxo.

4. Filtrar Artigos Recentes

É importante garantir que você só processe artigos que são realmente novos.

1. Conecte o nó RSS Feed Read a um nó If e nomeie-o como If published in the last hour.

2. Configure as seguintes condições para filtrar por data:

• Condição 1: Verifique se o campo string isoDate existe, use a expressão: {{ $json.isoDate }} exist.

• Condição 2: Verifique se a data do artigo é posterior a 1 hora atrás. Use a expressão: {{DateTime.fromISO($json.isoDate)}} is after {{DateTime.now().minus({hour: 1})}}

• Condição 3: Verifique se a data do artigo é anterior ou igual à data atual. Use a expressão: {{DateTime.fromISO($json.isoDate)}} is before or equal to {{DateTime.now()}}

• A condição entre a condição 1 e demais deve ser AND.

5. Gerar o Prompt para a IA

Para que a IA possa processar o conteúdo, é necessário formatar os dados de entrada antes.

1. Conecte a saída True do nó If published in the last hour a um nó Code e nomeie-o como Generate prompt.

2. Insira o código JavaScript fornecido no seu workflow para extrair e formatar o título, conteúdo e link do RSS em uma única string:

[for (const item of $input.all()) {

  let title = item.json.title || "N/A";

  let content = item.json.content || "N/A";

  let link = item.json.link || "N/A";

  title = title.replace(/\n/g, "").replace(/"/g, "");

  content = content.replace(/\n/g, "").replace(/"/g, "");

  link = link.replace(/\n/g, "").replace(/"/g, "");

  item.json.rss_content = `Título: ${title} | Conteúdo: ${content} | Link: ${link}`;

}

return $input.all();]

É importante salientar que estamos usando uma IA treinada exclusivamente para gerar resumos dado título, conteúdo e link. Portanto pode ser que você precise alterar o trecho acima para incluir o prompt para a IA entender o que deve ser feito com essa entrada. No nosso caso, a IA já tem o prompt embutido no modelo. Saiba mais sobre como rodar um modelo de IA localmente clicando aqui. É importante adicionar no prompt para que caso a notícia não seja relevante no contexto escolhido (exemplo, notícias sobre tecnologia), ela responda apenas: NÃO RELEVANTE

No n8n tem um bloco exclusivo para utilização de modelos de IA, se preferir utilize ele e configure a API do seu modelo de linguagem preferido. Este bloco deverá substituir o bloco AI AGENT Summarized da imagem abaixo (bloco HTTP).

6. Chamar o Agente de IA para Análise

Aqui você fará uma requisição para o seu servidor de IA local ou nuvem (API chatGPT por exemplo).

1. Conecte o nó Generate prompt a um nó Loop Over Items.

2. Conecte o nó Loop Over Items a um nó HTTP Request e nomeie-o como AI AGENT Summarized. Note que você pode modificar esse loop para usar um nó mais adequado ao seu contexto.

3. Configure o nó HTTP Request:

• Method: POST.

• URL: http://172.16.0.2:8080/api/chat/completions (ou o endereço do seu servidor de IA).

• Authentication: Use as credenciais httpBearerAuth para se autenticar.

• Body: Selecione JSON e cole o corpo JSON fornecido, usando a expressão {{ $json.rss_content }} para enviar o conteúdo do artigo à IA:

[{

      "model": "llama-rss",

      "messages": [

        {

          "role": "user",

          "content": "{{ $json.rss_content }}"

        }

      ]

}]

7. Filtrar Respostas da IA e Postar no Slack

O fluxo final verificará se a resposta da IA é relevante antes de postar no Slack.

1. Conecte o nó AI AGENT Summarized a um nó If e nomeie-o como If cybersecurity related.

2. Neste nó, configure uma condição para verificar se o resumo da IA não contém a string "NÃO RELEVANTE". Use a expressão {{ $json.choices[0].message.content }}. Pois assim garantimos que enviaremos apenas resumos gerados para a IA que seja relevante ao contexto escolhido, por exemplo notícias de tecnologia apenas.

3. Conecte a saída True do nó If tech related a um nó Wait.

4. No nó Wait, defina um tempo de espera para evitar problemas com limites de taxa do Slack. A espera de 30 segundos é uma boa prática.

5. Conecte o nó Wait a um nó Slack e nomeie-o como Post the news.

6. Configure o nó Slack com suas credenciais do Slack.

7. No campo Channel ID, selecione o canal para onde você quer postar (por exemplo, #rss-news).

8. No campo Text, use a expressão {{ $json.choices[0].message.content }} para postar o resumo fornecido pela IA.

Dessa forma, seu fluxo de trabalho estará pronto para ser ativado. Ele executará de forma autônoma a cada hora, entregando resumos relevantes de notícias diretamente no seu canal do Slack. Você pode alterar o fluxo para enviar um email ou realizar outras ações.