n8n构建ETL工作流

2025-06-12 722

n8n工作流自动化平台对用户的包容性极强,即使你不是技术专家,也能把AI功能集成到日常工作中。下面站长百科将通过详细图文的形式介绍如何通过n8n构建用于数据集成的ETL工作流。

一、设置Webhook接收数据

1、打开n8n工作流编辑器,点击中间或右上角的“+“按钮。

2、在搜索框输入“webhook“,选择“Webhook“节点。

3、设置HTTP方法为“POST“(就像设置一个“收件箱”)。

4、点击“POST URL“复制链接(这是你的“收件地址”)。

5、点击“Listen for test event“开始监听测试数据。

测试方法:用Postman发送测试请求(免费注册)。

新建HTTP请求→选POST→粘贴刚才复制的URL→点击发送。

结果会显示在右侧“OUTPUT“窗口。

提示:按“Ctrl+S“(Windows)或“Cmd+S“(Mac)保存,点击节点上的“Test step“或“Test workflow“重复测试。。

二、用HTTP Request提取数据

1、点击“+“,搜索并添加“HTTP Request“节点。

2、用箭头将Webhook节点连接到HTTP Request节点。

3、双击HTTP Request节点,设置:

  • HTTP方法:“GET“;
  • API URL:输入数据源链接(比如“https://my-json-server.typicode.com/“的测试URL)。
  • Query parameters:添加需要的字段(如“name“、“email“)。

点击“Test step“获取测试数据。

作用:这个节点就像“数据挖掘机”,从API中挖出你需要的信息。。

三、用Code Function转换数据

1、点击“+“,搜索并添加“Code Function“节点。

2、双击节点,用JavaScript修改数据格式(比如重命名字段、添加新内容)。

3、保存后点击“Test step“测试转换效果。

示例代码:

// 将数据格式化为Airtable需要的格式
return items.map(item => {
return {
json: {
Name: item.json.name,
Email: item.json.email,
// 添加其他需要的字段
。。}
。};
});

四、将数据加载到Airtable

1、点击“+“,搜索并添加“Airtable“节点。

2、选择“Create or update a record“操作。

3、连接Code Function节点和Airtable节点。

4、双击Airtable节点,设置:

操作:“Create or Update“。

字段映射:将转换后的数据对应到Airtable的列。

凭证:需要先在Airtable设置中添加API密钥。

注意:点击“Test step“插入测试数据,完成后点击“Test workflow“测试整个流程。

  • 广告合作

  • QQ群号:4114653

温馨提示:
1、本网站发布的内容(图片、视频和文字)以原创、转载和分享网络内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。邮箱:2942802716#qq.com(#改为@)。 2、本站原创内容未经允许不得转裁,转载请注明出处“站长百科”和原文地址。