CSV → 数据库 数据管道
第 6 部分 · 案例 5.1 · 🔄 数据管道
难度 🟡 中等 · 耗时 ~25 分钟 · 核心节点 GDrive Trigger × Extract × IF × Postgres
业务部门给你扔了 5000 行 CSV，让”导进数据库”。直接 import 失败一半（脏数据），手动清洗又烦——这个 workflow 自动监控指定 Drive 文件夹，新 CSV 来就解析、逐行验证、合法入库、问题行单独邮件告警。
🔍 工作流连线图
Section titled “🔍 工作流连线图” ▦ workflow csv-to-database.workflow.json Lv.2
📋 关键节点
Section titled “📋 关键节点” ⚙ key-config.txt
GDrive New CSV (Trigger):
Event: fileCreated
Folder: <监控的 Drive 文件夹>
File Type: csv
Extract from File:
Operation: CSV
→ 输出每行一个 item
Validate Row (IF):
邮箱合法 regex: ^[\w.-]+@[\w.-]+\.\w+$
→ True 路径 = 入库, False 路径 = 报错
Insert Postgres:
Operation: Insert
Table: customers
Columns: email, name, signup_date
Alert Bad Rows:
Subject: Invalid rows in CSV import
Text: ={{ JSON.stringify($json) }}
📥 一键复制 Workflow JSON
Section titled “📥 一键复制 Workflow JSON” 📋 csv-to-database.workflow.json