An n8n scheduled workflow that runs a daily 8 AM Postgres KPI query, computes day-over-day deltas, and evaluates each metric against configurable thresholds. Results are persisted to a Google Sheets KPI tracker and summarized in a Slack digest message. Any metric breaching its threshold triggers a separate Slack ops alert for immediate attention.

完整 FlowZap 代码

schedule { # Schedule
n1: rectangle label:"Schedule Trigger - Daily 08:00" system:"n8n"
n2: rectangle label:"Postgres - Query KPI Table" system:"Postgres"
n1.handle(right) -> n2.handle(left) [label="Run report"]
}

processing { # Processing
n3: rectangle label:"Code - Compute deltas vs yesterday" system:"n8n"
n4: diamond label:"IF: Any KPI outside threshold?" system:"n8n"
n2.handle(right) -> processing.n3.handle(left) [label="Raw KPIs"]
n3.handle(right) -> processing.n4.handle(left) [label="Evaluated"]
}

reporting { # Reporting
n5: rectangle label:"Google Sheets - Append KPI Row" system:"Google Sheets"
n6: rectangle label:"Slack - Post KPI Digest" system:"Slack"
processing.n3.handle(bottom) -> reporting.n5.handle(top) [label="Persist"]
reporting.n5.handle(right) -> reporting.n6.handle(left) [label="Send digest"]
}

alerts { # Alerts
n7: rectangle label:"Slack - Post Alert (#ops)" system:"Slack"
processing.n4.handle(right) -> alerts.n7.handle(left) [label="Yes → Alert"]
processing.n4.handle(bottom) -> reporting.n6.handle(top) [label="No → Digest only"]
}

相关模板