n8n로 매크로 데이터 워크플로를 자동화하는 방법

n8n은 비주얼 노드 편집기 (Visual Node Editor) 를 통해 API, 데이터베이스 및 SaaS 도구를 연결할 수 있는 자체 호스팅 가능한 오픈 소스 워크플로우 자동화 플랫폼입니다. 백엔드 인프라가 필요하지 않습니다. 매크로 데이터 워크 플로우에 대해 n8 n은 자연스러운 적합성입니다. 일정에서 지표 판독을 당겨, 다가오는 릴리스 캘린더 이벤트에 의해 필터링하고 결과를 Slack, Google 시트, 데이터베이스 또는 하류 웹 으로 푸시합니다. 모든 것이 시각적으로 구성되어 전용 서버 프로세스가 없이 24/7 실행됩니다. 이 가이드는 처음부터 n8 in에서 완전한 FXMacroData 자동화 워크 플로스를 구축하는 과정을 안내합니다.

단계 1 n8n을 시작 하 고 빈 작업 흐름을 생성

N8n을 로컬로 실행하는 가장 빠른 방법은 npx. Docker 또는 클라우드 버전을 선호하는 경우, 노드 구성은 동일합니다 작업 흐름을 만드는 데 계속 건너뛰십시오.

# 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

열어 http://localhost:5678 브라우저에서 계정을 만들고, 클릭합니다. + 새로운 작업 흐름 왼쪽 사이드바에서 빈 캔버스를 볼 수 있습니다. 파이프라인이 있는 곳이죠.

API 키를 n8n 자격증으로 저장하여 노드 구성에 내장되어 있지 않습니다. n8 n에서, 로 이동합니다. 설정 → 자격증 → 자격증을 추가 → HTTP 헤더 저작자 그리고 열쇠를 보관하세요:

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

다음 단계에서는 HTTP 요청 노드에서 저장된 인증서를 참조합니다.

단계 2 스케줄 트리거 노드를 추가

A 스케줄 트리거 노드는 정의된 간격에서 워크플로를 켜고, 매크로 데이터 워크프로에서는 런던 오픈 (07:30 UTC) 30분 전에 매일 트리거가 되어 하루의 첫 번째 유동성 높은 세션 전에 신선한 판독이 가능하도록 합니다.

클릭하세요 + 캔버스에 버튼을 눌러서 스케줄 트리거아래와 같이 설정하세요:

테스트를 위해, 트리거를 수동 일시적으로 이것은 스케줄을 기다리지 않고 캔버스에서 전체 워크플로를 클릭 한 번으로 실행할 수 있습니다.

Step 3 — Configure the HTTP Request node for FXMacroData

더해 HTTP 요청 스케줄 트리거 다음 노드 (클릭 + 트리거의 출력 연결에 켜고 HTTP 요청). 이 노드는 FXMacroData에 API 호출을 하고 JSON 응답을 직간접으로 작업 흐름에 반환합니다.

이 설정으로 노드를 구성합니다:

n8n의 HTTP 요청 노드는 전용 질의 매개 변수 테이블 한 줄 추가:

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

클릭하세요 노드를 실행 응답을 확인하기 위해

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

- announcement_datetime 이 값이 공식적으로 공개되었을 때 두 번째 수준의 정밀도를 제공합니다.

단계 4 코드 노드로 응답을 분석하고 변환

A를 더해 코드 HTTP 요청 노드 다음 노드에서 관심있는 필드를 추출하고 유료량을 풍부하게 만들기 위해. n8n의 코드 노드는 자바스크립트를 실행하고 이전 노드의 출력으로 완전히 액세스합니다. $input.all()-

// 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}`
    }
  };
});

이것은 각각의 항목에 대해 깨끗하고 풍부한 객체를 생성합니다. summary 이 필드는 Slack 메시지나 스프레드시트 행에 직접 붙여넣을 준비가 되었습니다.

단계 5 IF 노드로 조건 필터를 추가합니다

당신은 단지 릴리스가 진짜 새로운 경우에 하류 작업을 발사하고 싶어 API가 동일한 반환하지 않습니다 announcement_datetime 이미 이전 실행에서 처리했습니다. IF 코드 노드 다음 노드.

N8n을 사용하세요 정적 데이터 (코드 노드에서 접속할 수 있습니다. $getWorkflowStaticData 마지막 날까지 계속 지켜보도록 announcement_datetime

// 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 } };
});

그럼 를 설정해 IF 노드:

연결해 아니 노드에서 False 브랜치로 이동하면 새로운 릴리스가 인쇄되지 않은 날에는 오류 없이 작업 흐름이 깨끗하게 종료됩니다.

단계 6 Slack 또는 Discord에 알림을 보내

IF 노드 연결 사실 출력 a 노드 (또는 HTTP 요청 Discord webhook URL를 목표로 하는 노드). 코드 노드에서 부양된 필드를 사용하도록 메시지 본체를 구성합니다:

Discord에 대해서는 HTTP 요청 방법과 노드 POST 그리고 Discord webhook URL, 몸으로 설정:

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

설정 몸의 내용물 종류 JSON 그리고 노드는 자동으로 시리즈화를 처리합니다.

단계 7 구글 시트에 로그 공개

슬랙 알림과 병행하여 구글 시트 노드에서 영구적인 역사 로그를 유지하기 위해. 같은 IF 노드의 True 브랜치 출력으로 연결 (n8n는 여러 노드가 동일한 출력을 수신할 수 있습니다.)

구글 시트 노드를 구성합니다:

You will need to set up Google OAuth credentials in n8n under 설정 → 자격증 → 구글 시트 OAuth2 API 이 노드가 인증하기 전에 n8n의 내장 인증서 설정 가이드를 따르세요.

단계 8 출시 달력 사전 경고 분포를 추가

FXMacroData에 특유한 강력한 패턴은 발매 달력 최종점 발사할 수 있습니다 사전 경고 큰 영향력을 가진 인쇄 전에 숫자가 도달하기 전에 위치를 준비 할 수 있는 시간을 팀에게 제공합니다.

스케줄 트리거에 직접 연결된 두 번째 HTTP 요청 노드를 추가합니다.

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

다음 60분 이내에 일어나는 이벤트를 필터하는 코드 노드로 따라가세요:

// 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}`
      }
    }));
});

출력을 Slack 노드 (또는 Discord HTTP 요청) 에 연결하여 alert #macro-alerts channel. When no events are due within an hour, the filtered array is empty and n8n simply produces no output — no action is taken.

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

단계 9 작업 흐름을 활성화하고 모니터링

각 노드를 개별적으로 테스트한 후에 노드를 실행 버튼을 클릭하면 전체 작업 흐름을 끝에서 끝으로 실행합니다. 작업 흐름을 실행 도구줄에서 오류가 있는지 실행 로그를 확인합니다. n8n의 시각 디버거는 어떤 노드가 실패했는지 강조하고 그 단계의 정확한 입력/출력을 보여줍니다.

작업 흐름을 생산에 넣기 위해, 를 켜 액티브 오른쪽 상단에서 전환합니다. n8n는 이제 단계 2에서 정의한 cron 스케줄에서 자동으로 작업 흐름을 실행합니다.

단계 10 추가 지표 및 통화로 확장

당신이 만든 파이프 라인은 단일 통화에 대한 단일 지표를 목표로합니다. n8n의 시각적 가맹점이 FXMacroData URL 구조에 직접 지도를 내기 때문에 더 넓은 매크로 커버리지 세트로 확장하는 것은 간단합니다. 각 엔드포인트는 동일한 패턴을 따르고 있습니다:

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

하나의 작업 흐름 실행에서 여러 지표를 가져오기 위해, 추가 분할 트리거가 끝나고 의 리스트를 입력합니다. { currency, indicator } 쌍. 각 반복은 HTTP 요청 하나를 발사합니다. 아래 패턴은 세 개의 EUR 판독을 연속으로 가져옵니다:

// 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 } }];

그럼 을 더해 나뉘어 노드에서 배열을 개별 항목으로 확장하고 해당 항목을 HTTP 요청 노드와 연결합니다. HTTP 요청 URL에서 현재 항목의 필드를 참조하십시오:

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

이 단일 템플릿 패턴은 얼마나 많은 지표를 추적하든 워크플로우를 컴팩트하게 유지합니다. /api-data-docs 같은 {currency}/{indicator} 경로 구조는 전체에 적용됩니다.

요약

이제 n8n에서 실행되는 완전히 자동화된 매크로 데이터 파이프라인이 있습니다.

• 일일 cron 스케줄에서 트리거 (또는 요구에 따라)
• 쿼리 매개 변수 인증과 함께 HTTP 요청을 통해 최신 FXMacroData 지표를 가져옵니다
• 코드 노드에서 방향 신호로 JSON 응답을 분석하고 부양합니다
• 마지막에 보인 것과 비교해서 announcement_datetime 두 번 경고를 방지하기 위해
• 새 릴리스가 인쇄될 때 Slack 또는 Discord 알림을 전송합니다
• 모든 새로운 읽기들을 Google Sheets 로그에 추가하여 역사 분석을 합니다
• 화재는 예정된 큰 영향의 사건보다 한 시간 전에 사전 캘린더 경고

여기서, 자연스러운 다음 단계는 지표 목록에 더 많은 통화를 추가하고, 시각화를 위해 엽서를 롤러 스튜디오 대시보드에 연결하거나, 새로운 릴리스에 직접 주문 알림을 트리거하기 위해 거래 플랫폼 웹 과 통합하는 것을 포함합니다. 같은 n8n HTTP 요청 패턴은 모든 FXMacroData 엔드포인트에 작동합니다. 전체 API 문서 전체 지표 카탈로그를 발견하고 자신의 거시 지능 계층을 구축하기 시작하십시오.