Como automatizar os fluxos de trabalho de dados macro com n8n

n8n é uma plataforma de automação de fluxo de trabalho auto-hospedável, de código aberto, que permite conectar APIs, bancos de dados e ferramentas SaaS através de um editor de nó visual sem infraestrutura de backend necessária. Para fluxos de trabalho de dados macro, n8 n é uma adaptação natural: puxe leituras de indicadores em um cronograma, filtre por eventos de calendário de lançamento próximos e empurre resultados para Slack, Google Sheets, um banco de dados ou qualquer webhook a jusante tudo configurado visualmente e funcionando 24 horas por dia e 7 dias por semana sem um processo de servidor dedicado.

Passo 1 Iniciar n8n e criar um fluxo de trabalho em branco

A maneira mais rápida de fazer N8N localmente é com npx. Se você preferir o Docker ou a versão em nuvem, a configuração do nó é idêntica pule para a criação do fluxo de trabalho.

# Local quick-start (Node.js 18+ required)
npx n8n

# Or with Docker
docker run -it --rm \
  -p 5678:5678 \
  -v ~/.n8n:/home/node/.n8n \
  n8nio/n8n

Abre . http://localhost:5678 no seu navegador, crie uma conta e clique em + Novo fluxo de trabalho Você verá uma tela em branco este é o lugar onde o gasoduto vive.

Armazenar sua chave de API como uma credencial n8n para que nunca seja incorporada em configurações de nó. Configurações → Credenciais → Adicionar credenciais e guarda a tua chave:

Name:  FXMacroData API Key
Header Name: (leave blank — we use query params)
Value: YOUR_FXMACRODATA_API_KEY

Você vai fazer referência a esta credencial armazenada no nó de solicitação HTTP na próxima etapa.

Passo 2 Adicionar um nó de desencadeamento de programação

A . Ativador de programação O nó inicia o fluxo de trabalho em um intervalo definido. Para os fluxos de trabalho de dados macro, um gatilho diário 30 minutos antes da abertura de Londres (07:30 UTC) garante que leituras frescas estejam disponíveis antes da primeira sessão de alta liquidez do dia.

Clique no + O botão na tela e procure por Ativador de programaçãoConfigure-o da seguinte forma:

Para testes, desligue o gatilho para Manual temporariamente permite executar o fluxo de trabalho completo a partir da tela com um único clique sem esperar pela programação.

Passo 3 Configure o nó de solicitação HTTP para FXMacroData

Adicione um Solicitação HTTP nó após o gatilho de programação (clique no + no conector de saída do gatilho e procure por Solicitação HTTPEste nó faz a chamada API para FXMacroData e retorna a resposta JSON diretamente no fluxo de trabalho.

Configure o nó com estas configurações:

O nó de solicitação HTTP do n8n tem um dedicado Parâmetros da consulta Tabela adicionar uma linha:

Name:  api_key
Value: {{ $credentials.fxmacrodataApiKey.value }}
       (or paste your key directly for quick testing)

Clique . Execução de nó Você deve ver uma saída semelhante a:

{
  "currency": "EUR",
  "indicator": "policy_rate",
  "date": "2025-06-12",
  "val": 3.40,
  "prior": 3.65,
  "announcement_datetime": "2025-06-12T13:15:00Z"
}

O ... announcement_datetime O campo de dados do sistema de segurança do sistema fornece uma precisão de segundo nível sobre quando este valor foi oficialmente publicado use-o como a chave de deduplicação para que o seu fluxo de trabalho nunca faça alertas duplos na mesma versão.

Passo 4 Analisar e transformar a resposta com um nó de código

Adicione um . Código nó após o nó de solicitação HTTP para extrair os campos que você se importa e enriquecer a carga útil. nó de código n8n executa JavaScript e tem acesso total à saída do nó anterior através $input.all()- Não .

// Code node: parse FXMacroData announcement response
const items = $input.all();

return items.map(item => {
  const d = item.json;

  // Determine direction relative to prior value
  const direction =
    d.val > d.prior ? "↑ Hawkish signal" :
    d.val < d.prior ? "↓ Dovish signal"  : "→ Unchanged";

  const surpriseText =
    d.consensus != null
      ? `Consensus was ${d.consensus}; actual ${d.val > d.consensus ? "beat" : "missed"}.`
      : "";

  return {
    json: {
      currency:              d.currency,
      indicator:             d.indicator,
      value:                 d.val,
      prior:                 d.prior,
      direction,
      surprise:              surpriseText,
      announcement_datetime: d.announcement_datetime,
      summary: `${d.currency.toUpperCase()} ${d.indicator.replace(/_/g, " ")}: ` +
               `${d.val} (prior ${d.prior}) — ${direction}`
    }
  };
});

Isto produz um objeto limpo e enriquecido para cada item. summary campo está pronto para colar diretamente em uma mensagem Slack ou linha de planilha.

Passo 5 Adicionar um filtro condicional com um nó IF

Você só quer disparar ações a jusante quando a versão é genuinamente nova não se a API retornar a mesma announcement_datetime Você já processou em uma execução anterior. Se nó após o nó de código.

Use o n8n. Dados estáticos (acessível através do nó do código $getWorkflowStaticData Para persistir no último visto . announcement_datetime Entre as corridas:

// Code node: deduplication guard — place before the IF node
const staticData = $getWorkflowStaticData("global");

return $input.all().map(item => {
  const ts = item.json.announcement_datetime;
  const isNew = ts !== staticData.lastSeen;

  // Update state only if this is a new release
  if (isNew) {
    staticData.lastSeen = ts;
  }

  return { json: { ...item.json, isNew } };
});

Então configure o Se nó:

Liga-me a um Não, não. nó para o ramo Falso para que o fluxo de trabalho saia limpo sem erros nos dias em que nenhuma nova versão foi impressa.

Passo 6 Enviar notificações para Slack ou Discord

Conecte o nó IF. É verdade. saída para a Descalço Nodo (ou um Solicitação HTTP Node que visa um URL do webhook do Discord). Configure o corpo da mensagem para usar os campos enriquecidos do nó do código:

Para Discord, use um Solicitação HTTP nó com método POST e o URL do webhook do Discord, com o corpo definido para:

{
  "content": "📊 **New macro release**\n{{ $json.summary }}\n{{ $json.surprise }}\nPublished: {{ $json.announcement_datetime }}"
}

- Está pronto . Tipo de conteúdo do corpo Para JSON e o nó irá lidar com serialização automaticamente.

Passo 7 Lançamentos de log para Google Sheets

Paralelamente à notificação do Slack, adicione um Google Sheets Conecte-o à mesma saída de ramo verdadeiro do nó IF (n8n permite que vários nós recebam a mesma saída).

Configure o nó do Google Sheets:

Você precisará configurar credenciais do Google OAuth em n8n abaixo Configurações → Credenciais → Google Sheets API OAuth2 Antes que este nó possa autenticar. Siga o guia de configuração de credenciais embutida do n8n leva cerca de dois minutos.

Passo 8 Adicionar um ramo de pré-alerta do calendário de lançamento

Um padrão poderoso exclusivo do FXMacroData é o uso do ponto final do calendário de liberação Para disparar . avisos antecipados antes de uma impressão de alto impacto dando tempo à sua equipa para preparar posições antes que o número atinja.

Adicionar um segundo nó de solicitação HTTP conectado diretamente ao trigger de programação (paralelamente à busca de anúncios). Configure-o para puxar versões futuras para a semana atual:

Method: GET
URL:    https://fxmacrodata.com/api/v1/calendar/eur
Params: api_key=YOUR_API_KEY

Siga isto com um nó de código que filtra eventos que acontecem nos próximos 60 minutos:

// Code node: filter calendar events due within the next hour
const nowMs  = Date.now();
const oneHrMs = 60 * 60 * 1000;

return $input.all().flatMap(item => {
  const events = Array.isArray(item.json) ? item.json : [item.json];

  return events
    .filter(ev => {
      const evMs = new Date(ev.release_datetime).getTime();
      return evMs > nowMs && evMs <= nowMs + oneHrMs;
    })
    .map(ev => ({
      json: {
        currency:         ev.currency,
        indicator:        ev.indicator,
        release_datetime: ev.release_datetime,
        alert: `⏰ *Upcoming release in <1 hour*\n` +
               `${ev.currency.toUpperCase()} ${ev.indicator.replace(/_/g, " ")}\n` +
               `Scheduled: ${ev.release_datetime}`
      }
    }));
});

Conecte a saída a um nó Slack (ou Discord HTTP Request) que envia o alert Campo para o teu ... #macro-alerts Quando não há eventos dentro de uma hora, a matriz filtrada está vazia e n8n simplesmente não produz nenhuma saída nenhuma ação é tomada.

https://fxmacrodata.com/api/v1/announcements/{{ $vars.currency }}/policy_rate?api_key=YOUR_API_KEY

Passo 9 Ativar e monitorizar o fluxo de trabalho

Depois de testar cada nó individualmente usando o Execução de nó botão, execute o fluxo de trabalho completo de ponta a ponta clicando Execute o fluxo de trabalho Verifique o log de execução para quaisquer erros o depurador visual do n8n destaca qual nó falhou e mostra a entrada/saída exata naquela etapa.

Para colocar o fluxo de trabalho em produção, alternar o Atividade Mudar no canto superior direito. n8n agora executará o fluxo de trabalho automaticamente no cron programa que você definiu na etapa 2.

Passo 10 Extensão para indicadores e moedas adicionais

O pipeline que você construiu tem como alvo um único indicador para uma única moeda. Estendê-lo para um conjunto de cobertura macro mais amplo é simples porque os mapas de ramificação visual do n8n diretamente para a estrutura do URL FXMacroData. Cada endpoint segue o mesmo padrão:

https://fxmacrodata.com/api/v1/announcements/{currency}/{indicator}?api_key=YOUR_API_KEY

Para obter vários indicadores em uma execução de fluxo de trabalho, adicione um Dividido em lotes Nodo após o gatilho e alimenta-lo com uma lista de { currency, indicator } Cada iteração dispara uma solicitação HTTP. O padrão abaixo traz três leituras EUR em sequência:

// Set node: define the indicator list
// Add this as a "Set" node at the top, outputting a single item
// with a field named "indicators"

const indicators = [
  { currency: "eur", indicator: "policy_rate" },
  { currency: "eur", indicator: "inflation" },
  { currency: "eur", indicator: "unemployment" }
];

return [{ json: { indicators } }];

Então adicione um Divididos node para expandir a matriz em itens individuais, e conectar esses itens ao nó de solicitação HTTP. No URL de solictação HTTP, faça referência aos campos do item atual:

URL: https://fxmacrodata.com/api/v1/announcements/{{ $json.currency }}/{{ $json.indicator }}
Params: api_key=YOUR_API_KEY

Este padrão de modelo único mantém o fluxo de trabalho compacto, independentemente de quantos indicadores você acompanha. /api-data-docs O mesmo . {currency}/{indicator} A estrutura do caminho é aplicável em toda a parte.

Resumo

Agora você tem um pipeline de dados macro totalmente automatizado em execução em n8n que:

• Ativadores em cron programação de dias úteis (ou sob demanda)
• Obtém o último indicador FXMacroData através de solicitação HTTP com autenticação de parâmetros de consulta
• Parseia e enriquece a resposta JSON com sinais direcionais em um nó de código
• Deduplicados contra o último visto . announcement_datetime Para evitar alertas duplos
• Envia notificações Slack ou Discord quando uma nova versão é impressa
• Adiciona cada nova leitura a um log do Google Sheets para análise histórica
• Incêndios alertas calendário antecipados até uma hora antes de eventos de alto impacto programados

A partir daqui, os próximos passos naturais incluem adicionar mais moedas à lista de indicadores, conectar o log de folhas a um painel de controle do Looker Studio para visualização ou integrar com um webhook de plataforma de negociação para acionar alertas de ordem diretamente em novas versões. documentação completa da API para descobrir o catálogo completo de indicadores e começar a construir a sua própria camada de inteligência macro.