マルチチャネル・データベース連携型タスクリマインダーシステム - n8n ワークフロー

通知マイクロサービスを構築するシステム管理者や開発者
中央集権的で設定可能なリマインダー スケジューリングを必要とするチーム
マルチチャネル通信のための堅牢で複雑なn8nテンプレートを探しているユーザー
n8nを使用した回復力のあるデータベース駆動型オートメーションソリューションを必要とするすべての人

この堅牢なオートメーションは、信頼性の高いマルチチャネルタスク通知システムを構築するという課題を解決します。n8nワークフローを活用し、専用Webhook経由でタスクを取り込み、PostgreSQLデータベースに安全に保存します。このシステムの重要な部分は、定期的に期日を過ぎたタスクをチェックするスケジュール設定されたn8nトリガーです。主な価値は、動的なルーティング機能にあり、タスク作成時にユーザーが希望するコミュニケーションチャネル（Eメール、Slack、またはTelegram）を指定できます。この高度なn8nワークフローアーキテクチャにより、ミッションクリティカルなリマインダーが最も見られやすい場所へ確実に配信されるため、n8nオートメーションコレクションにおいて非常に価値の高い追加機能となります。このテンプレートは、n8nワークフロー内でのデータ管理とフロー制御におけるPostgreSQL n8nノード使用のベストプラクティスを示しています。

このn8nワークフローは、「タスクの取り込み」と「リマインダー配信」の2つの主要コンポーネントで構成されています。

1. タスクの取り込み (Webhook - Receive Task n8n トリガー): 外部アプリケーションが 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. リマインダー配信 (Schedule Trigger): このn8nワークフローの後半部分は、cronスケジュール (/5 *) で実行される Schedule Trigger - Every 5 Minutes n8nトリガーによって開始されます。


5. データベースクエリ: Fetch Due Tasks n8nノードがPostgreSQLに対して、reminder_timeが近づいているか超過しており、ステータスが保留中のタスクを照会します。


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をコピーし、n8nインスタンスの「新規作成」メニュー > 「JSONからインポート」を使用して貼り付けます。


2. PostgreSQLの設定: Save Task to Database、Fetch Due Tasks、Update Task Status n8nノードで使用されるPostgreSQL認証情報を設定します。データベースに、付箋に記載されているスキーマを含む tasks テーブルが存在することを確認してください。


3. コミュニケーション認証情報の設定: リマインダー配信用のn8nノードの認証情報を設定します。

1. Webhookのアクティベート: Webhook - Receive Task n8nトリガーからWebhook URLをコピーし、タスク作成システムに統合します。


2. 有効化: スケジュールトリガーが実行を開始するように、n8nワークフローが「アクティブ」に設定されていることを確認します。

このn8nワークフローは、堅牢な機能を果​​たすためにいくつかの重要なn8nノードを使用しています。

Webhook - Receive Task (n8n トリガー): 主要なエントリーポイント。新しいタスク作成リクエストを受け取るため、特定のパス (task-YOUROPENAIKEYHERE-webhook) をリッスンします。
Postgres Node (Save Task to Database): 検証済みのタスクデータを保存します。主な設定には、操作を「Insert」に設定し、対象テーブル（暗黙的に tasks テーブル）を指定することが含まれます。
Schedule Trigger - Every 5 Minutes (n8n トリガー): cron式 /5 を使用して、リマインダーチェックプロセスを定期的に開始します。
Postgres Node (Fetch Due Tasks): カスタムSQLクエリ (SELECT FROM tasks WHERE status = 'pending' AND remindertime <= NOW() + INTERVAL '5 minutes' AND remindertime > NOW()) を実行し、関連レコードを取得します。
If Node (Validate Input & Check Tasks Exist): フロー制御に不可欠です。バリデーションノードは主要な入力が空でないかを確認します。存在チェックは、データベースがアイテムを返したかどうかを確認します。
Switch Node (Route by Channel): タスクの channel フィールドに基づいてリマインダー配信パスを決定し、n8nフローをEメール（出力0）、Slack（出力1）、またはTelegram（出力2）に接続します。
Email Send Node (Send Email Reminder): パーソナライズされた件名 (⏰ Task Reminder: {{ $json.taskname }}) と本文で、userid にメッセージを送信するように設定されています。
Slack Node (Send Slack Reminder): データベースアイテムから取得した userid を介してユーザーに動的に言及する、フォーマットされたMarkdownメッセージを送信します。
Telegram Node (Send Telegram Reminder): ターゲットの chatId ({{ $json.userid }}) に対して、Markdown形式を使用してメッセージを送信します。
Postgres Node (Update Task Status): status = 'sent' および sentat = NOW() に設定する UPDATE クエリを実行し、この強力なn8nノード実装のループを完了させます。