
## 工作流概述
这个n8n工作流模板用于监控Postgres数据库中的表数据更新状态,确保数据保持新鲜。当表数据超过设定的时间阈值(默认为3天)未更新时,系统会自动发送邮件警报通知相关人员。
## 核心功能
### 数据新鲜度监控
– 定期检查指定Postgres表中的数据更新时间
– 计算每个表的数据滞后天数
– 识别超过阈值未更新的”陈旧”表
### 智能警报机制
– 可配置的陈旧数据阈值(默认3天)
– 自动聚合所有陈旧表信息
– 通过执行工作流节点发送定制化邮件警报
## 技术实现
### 节点流程
1. **Schedule Trigger** – 定时触发工作流执行
2. **Code Node** – 生成要监控的表名和时间戳列对
3. **SplitInBatches** – 循环处理每个表
4. **Postgres Node** – 从每个表中获取最新行数据
5. **DateTime Node** – 计算数据滞后时间
6. **Set Node** – 添加表名和滞后天数信息
7. **Filter Node** – 过滤掉新鲜的表数据
8. **Aggregate Node** – 聚合所有陈旧表信息
9. **ExecuteWorkflow** – 发送警报通知
### 配置要求
– 需要Postgres数据库凭证
– 每个监控表必须包含日期或时间戳列
– 可选的邮件发送工作流配置
## 应用场景
– 监控数据管道的数据更新状态
– 确保业务关键数据的及时性
– 数据质量监控和告警
– 自动化数据新鲜度检查
## 优势特点
– **高度可配置**:可自定义监控表和陈旧阈值
– **自动化运行**:定时自动执行,无需人工干预
– **灵活扩展**:支持多种警报方式和工作流集成
– **易于部署**:基于n8n平台,快速搭建和配置

评论(0)