用途:构建数据集成、转换与分析自动化的数据管道和 ETL 工作流,基于 n8n 的数据工作流模板。
主要能力:抽取支持数据库(PostgreSQL、MySQL、MongoDB)、API(REST、GraphQL)、文件(CSV、Excel、JSON)及 SaaS(Salesforce、HubSpot、Stripe、Shopify);转换涵盖清洗(去空、去重、校验)、字段映射与类型转换、聚合(分组、求和、计数、平均)、富化(查表、地理编码、派生字段)与过滤;加载支持数据仓库(BigQuery、Snowflake、Redshift)、数据库、文件(S3、GCS)、表格(Google Sheets、Airtable)与 Webhook。还提供调度(cron 小时/日/周、按需触发、依赖与重试)、监控告警(行数、执行时间、错误数、数据新鲜度,失败与数据质量异常通知 Slack、PagerDuty)以及数据质量检查(模式校验、统计检查、业务规则、趋势分析)。
使用方式:以 YAML 定义 workflow、schedule 与 nodes,节点分抽取、转换、加载三段;转换可用 code 节点编写 JavaScript 函数(如 transform、aggregate)。示例中每日 2am 运行,从 Shopify 与 Stripe 抽取后合并、转换并写入 BigQuery 与 Google Sheets。
适用场景:日常销售报表、数据仓库同步、跨系统数据整合与临时分析。
限制:资料未提供具体安装命令、收费、价格、平台支持范围与效果数据;实际可用性取决于 n8n 环境与各数据源连接配置。