다채널 데이터베이스 기반 작업 알림 시스템 - n8n 워크플로우

알림 마이크로서비스를 구축하는 시스템 관리자 및 개발자.
중앙 집중식 구성 가능 알림 스케줄링이 필요한 팀.
다채널 통신을 위한 견고하고 복잡한 n8n 템플릿을 찾는 사용자.
n8n을 사용한 안정적인 데이터베이스 기반 자동화 솔루션이 필요한 모든 사람.

이 강력한 자동화는 안정적인 다채널 작업 알림 시스템 구축의 과제를 해결합니다. n8n 워크플로우를 활용하여 전용 웹훅을 통해 작업을 수집하고 PostgreSQL 데이터베이스에 안전하게 저장합니다. 이 시스템의 중요한 부분은 정기적으로 마감된 작업을 확인하는 예약된 n8n 트리거입니다. 핵심 가치 제안은 동적 라우팅 기능에 있으며, 사용자는 작업을 생성할 때 선호하는 통신 채널(이메일, Slack 또는 Telegram)을 지정할 수 있습니다. 이 고급 n8n 워크플로우 아키텍처는 중요한 알림이 가장 잘 보일 가능성이 높은 곳으로 안정적으로 전달되도록 보장하므로 모든 n8n 자동화 모음에 매우 유용한 추가 기능이 됩니다. 이 템플릿은 n8n 워크플로우 내에서 데이터 관리 및 흐름 제어를 위해 PostgreSQL n8n 노드를 사용하는 모범 사례를 보여줍니다.

n8n 워크플로우는 작업 수집(Task Ingestion)과 알림 배포(Reminder Distribution)라는 두 가지 주요 구성 요소로 구조화됩니다.

1. 작업 수집 (웹훅 트리거): 외부 애플리케이션이 Webhook - Receive Task n8n 트리거를 호출하여 작업 세부 정보가 포함된 JSON 페이로드를 제출하면 프로세스가 시작됩니다.


2. 검증: Validate Input n8n 노드는 제약 조건을 적용하여 userId, taskName, reminderTime이 제공되었는지 확인합니다. 여기서 실패하면 즉시 Error Response가 반환됩니다.


3. 지속성: 유효한 작업은 Save Task to Database n8n 노드로 전달되어 'pending'(보류 중) 상태로 PostgreSQL에 저장됩니다. 성공적인 작업은 긍정적인 Success Response를 보냅니다.


4. 알림 배포 (예약 트리거): 이 n8n 워크플로우의 두 번째 부분은 Schedule Trigger - Every 5 Minutes n8n 트리거에 의해 시작되며, 이는 크론 스케줄(/5 *)에 따라 실행됩니다.


5. 데이터베이스 쿼리: Fetch Due Tasks n8n 노드는 reminder_time이 다가오거나 지난 보류 중인 작업을 PostgreSQL에서 쿼리합니다.


6. 흐름 제어: Check Tasks Exist n8n 노드는 레코드를 검색한 경우에만 흐름이 계속되도록 보장합니다. 그런 다음 흐름은 Split Into Items n8n 노드를 사용하여 레코드를 분할하여 각 작업을 독립적으로 처리합니다.


7. 채널 라우팅: Route by Channel n8n 노드는 channel 필드(email, slack 또는 telegram)의 값을 기반으로 작업을 동적으로 라우팅합니다.


8. 알림 및 전송: 적절한 통신 n8n 노드(Send Email Reminder, Send Slack Reminder 또는 Send Telegram Reminder)가 맞춤화된 알림 메시지를 전달합니다.


9. 완료: 마지막으로 Update Task Status n8n 노드가 PostgreSQL의 작업을 'sent'(전송됨)로 업데이트하여 이 강력한 n8n 워크플로우의 향후 실행에서 중복 알림이 발생하는 것을 방지합니다.

이 포괄적인 n8n 워크플로우를 배포하려면 다음 단계를 따르세요.

1. JSON 가져오기: 제공된 n8n 워크플로우 JSON을 복사하여 'New' 메뉴 > 'Import from JSON'을 사용하여 n8n 인스턴스에 붙여넣습니다.


2. PostgreSQL 설정: Save Task to Database, Fetch Due Tasks, Update Task Status n8n 노드에서 사용하는 PostgreSQL 자격 증명을 구성합니다. 데이터베이스에 스티커 메모에 제공된 스키마를 가진 tasks 테이블이 있는지 확인하세요.


3. 통신 자격 증명: 알림 전송 n8n 노드에 대한 자격 증명을 설정합니다.

1. 웹훅 활성화: Webhook - Receive Task n8n 트리거에서 웹훅 URL을 복사하여 작업 생성 시스템에 통합합니다.


2. 활성화: 예약된 트리거가 실행되도록 n8n 워크플로우가 'Active'(활성)로 표시되어 있는지 확인합니다.

이 n8n 워크플로우는 강력한 기능을 구현하기 위해 여러 중요한 n8n 노드를 사용합니다.

Webhook - Receive Task (n8n 트리거): 기본 진입점입니다. 새 작업 생성 요청을 수신하기 위해 특정 경로(task-YOUROPENAIKEYHERE-webhook)에서 수신 대기합니다.
Postgres 노드 (Save Task to Database): 검증된 작업 데이터를 저장합니다. 주요 구성에는 작업을 'Insert'(삽입)로 설정하고 대상 테이블(tasks 테이블로 가정)을 지정하는 것이 포함됩니다.
Schedule Trigger - Every 5 Minutes (n8n 트리거): 크론 표현식(/5 )을 사용하여 주기적으로 알림 확인 프로세스를 시작합니다.
Postgres 노드 (Fetch Due Tasks): 관련 레코드를 검색하기 위해 사용자 지정 SQL 쿼리(SELECT FROM tasks WHERE status = 'pending' AND remindertime <= NOW() + INTERVAL '5 minutes' AND remindertime > NOW())를 실행합니다.
If 노드 (Validate Input & Check Tasks Exist): 흐름 제어에 필수적입니다. 검증 노드는 주요 입력값이 비어 있지 않은지 확인합니다. 존재 여부 확인은 데이터베이스가 항목을 반환했는지 확인합니다.
Switch 노드 (Route by Channel): 작업의 channel 필드에 따라 알림 전송 경로를 결정하며, n8n 흐름을 이메일(출력 0), Slack(출력 1) 또는 Telegram(출력 2)에 연결합니다.
Email Send 노드 (Send Email Reminder): 맞춤형 제목(⏰ 작업 알림: {{ $json.taskname }})과 본문 내용을 userid로 보내도록 구성됩니다.
Slack 노드 (Send Slack Reminder): 데이터베이스 항목에서 검색된 userid를 통해 사용자에게 동적으로 주소를 지정하는 서식이 지정된 마크다운 메시지를 보냅니다.
Telegram 노드 (Send Telegram Reminder): 대상 chatId({{ $json.userid }})로 마크다운 서식을 사용하여 메시지를 보냅니다.
Postgres 노드 (Update Task Status): status = 'sent' 및 sentat = NOW()로 설정하기 위해 UPDATE 쿼리를 실행하여 이 강력한 n8n 노드 구현의 루프를 완료합니다.