合并和拆分数据#

在本章中，您将学习如何合并和拆分数据，以及在什么情况下执行这些操作可能有用。

合并数据#

在某些情况下，您可能需要合并（组合）和处理来自不同来源的数据。

合并数据可能涉及：

从多个来源创建一个数据集。
在多个系统之间同步数据。这可能包括删除重复数据或在一个系统中的数据更改时更新另一个系统中的数据。

单向 vs. 双向同步

在单向同步中，数据在一个方向上同步。一个系统作为唯一的真相来源。当主系统中的信息发生变化时，它会自动在辅助系统中发生变化；但如果辅助系统中的信息发生变化，更改不会反映在主系统中。

在双向同步中，数据在两个方向上同步（在两个系统之间）。当两个系统中任何一个的信息发生变化时，它会自动在另一个系统中发生变化。

这个博客教程解释了如何在两个 CRM 之间进行单向和双向数据同步。

在 n8n 中，您可以使用合并节点合并来自两个不同节点的数据，该节点提供几种合并选项：

注意，组合 > 按字段合并需要您输入要匹配的输入字段。这些字段应该在数据源之间包含相同的值，以便 n8n 可以正确地将数据匹配在一起。在合并节点中，它们被称为 Input 1 Field 和 Input 2 Field。

点表示法中的属性输入

如果您想在合并节点参数 Input 1 Field 和 Input 2 Field 中引用嵌套值，您需要以点表示法格式输入属性键（作为文本，而不是表达式）。

Note

您还可以在别名 Join 下找到合并节点。如果您熟悉 SQL 连接，这可能更直观。

合并练习#

构建一个工作流，合并来自客户数据存储节点和代码节点的数据。

添加一个合并节点，它从客户数据存储节点获取 Input 1，从代码节点获取 Input 2。
在客户数据存储节点中，运行操作 Get All People。
在代码节点中，创建一个包含两个对象的数组，每个对象有三个属性：name、language 和 country，其中属性 country 有两个子属性 code 和 name。
- 用来自客户数据库的两个角色的信息填写这些属性的值。
- 例如，Jay Gatsby 的语言是英语，国家名称是美国。
在合并节点中，尝试不同的合并选项。

显示解决方案

此练习的工作流如下所示：

如果您使用选项 Keep Matches 使用名称作为要匹配的输入字段合并数据，结果应该如下所示（注意此示例仅包含 Jay Gatsby；根据您选择的角色，您的可能看起来不同）：

要检查节点的配置，您可以复制下面的 JSON 工作流代码并将其粘贴到您的编辑器 UI 中：

{
"meta": {
	"templateCredsSetupCompleted": true,
	"instanceId": "cb484ba7b742928a2048bf8829668bed5b5ad9787579adea888f05980292a4a7"
},
"nodes": [
	{
	"parameters": {
		"mode": "combine",
		"mergeByFields": {
		"values": [
			{
			"field1": "name",
			"field2": "name"
			}
		]
		},
		"options": {}
	},
	"id": "578365f3-26dd-4fa6-9858-f0a5fdfc413b",
	"name": "Merge",
	"type": "n8n-nodes-base.merge",
	"typeVersion": 2.1,
	"position": [
		720,
		580
	]
	},
	{
	"parameters": {},
	"id": "71aa5aad-afdf-4f8a-bca0-34450eee8acc",
	"name": "When clicking \"Execute workflow\"",
	"type": "n8n-nodes-base.manualTrigger",
	"typeVersion": 1,
	"position": [
		260,
		560
	]
	},
	{
	"parameters": {
		"operation": "getAllPeople"
	},
	"id": "497174fe-3cab-4160-8103-78b44efd038d",
	"name": "Customer Datastore (n8n training)",
	"type": "n8n-nodes-base.n8nTrainingCustomerDatastore",
	"typeVersion": 1,
	"position": [
		500,
		460
	]
	},
	{
	"parameters": {
		"jsCode": "return [\n  {\n    'name': 'Jay Gatsby',\n    'language': 'English',\n    'country': {\n      'code': 'US',\n      'name': 'United States'\n    }\n    \n  }\n  \n];"
	},
	"id": "387e8a1e-e796-4f05-8e75-7ce25c786c5f",
	"name": "Code",
	"type": "n8n-nodes-base.code",
	"typeVersion": 2,
	"position": [
		500,
		720
	]
	}
],
"connections": {
	"When clicking \"Execute workflow\"": {
	"main": [
		[
		{
			"node": "Customer Datastore (n8n training)",
			"type": "main",
			"index": 0
		},
		{
			"node": "Code",
			"type": "main",
			"index": 0
		}
		]
	]
	},
	"Customer Datastore (n8n training)": {
	"main": [
		[
		{
			"node": "Merge",
			"type": "main",
			"index": 0
		}
		]
	]
	},
	"Code": {
	"main": [
		[
		{
			"node": "Merge",
			"type": "main",
			"index": 1
		}
		]
	]
	}
},
"pinData": {}
}

循环#

在某些情况下，您可能需要对数组的每个元素或每个数据项目执行相同的操作（例如向通讯录中的每个联系人发送消息）。在技术术语中，您需要遍历数据（使用循环）。

n8n 通常自动处理这种重复处理，因为节点对每个项目运行一次，所以您不需要在工作流中构建循环。

但是，有一些节点和操作的例外，需要您在工作流中构建循环。

要在 n8n 工作流中创建循环，您需要将一个节点的输出连接到前一个节点的输入，并添加一个 If 节点 来检查何时停止循环。

分批拆分数据#

如果您需要处理大量传入数据、多次执行代码节点或避免 API 速率限制，最好将数据拆分为批次（组）并处理这些批次。

对于这些过程，使用循环遍历项目节点。此节点将输入数据拆分为指定的批次大小，并在每次迭代中返回预定义数量的数据。

循环遍历项目节点的执行

循环遍历项目节点 在所有传入项目被分成批次并传递给工作流中的下一个节点后停止执行，因此不需要添加 If 节点 来停止循环。

循环/批次练习#

构建一个工作流，读取来自 Medium 和 dev.to 的 RSS 订阅源。工作流应包含三个节点：

一个代码节点，返回 Medium（https://medium.com/feed/n8n-io）和 dev.to（https://dev.to/feed/n8n）RSS 订阅源的 URL。
一个具有 Batch Size: 1 的循环遍历项目节点，它接收来自代码节点和 RSS 读取节点 的输入并遍历项目。
一个 RSS 读取节点，获取 Medium RSS 订阅源的 URL，作为表达式传递：{{ $json.url }}。
- RSS 读取节点 是例外节点之一，它只处理接收到的第一个项目，因此需要循环遍历项目节点来遍历多个项目。

显示解决方案

添加一个代码节点。您可以通过几种方式格式化代码，一种方式是：

将模式设置为 Run Once for All Items。
将语言设置为 JavaScript。

复制下面的代码并将其粘贴到 JavaScript 代码编辑器中：

let urls = [
	{
		json: {
		url: 'https://medium.com/feed/n8n-io'
		}
	},
	{
	json: {
		url: 'https://dev.to/feed/n8n'
		} 
	}
]
return urls;

添加连接到代码节点的循环遍历项目节点。
- 将批次大小设置为 1。
循环遍历项目节点 自动添加一个名为"Replace Me"的节点。用 RSS 读取节点 替换该节点。
- 将 URL 设置为使用来自代码节点的 url：{{ $json.url }}。

此练习的工作流如下所示：

要检查节点的配置，您可以复制下面的 JSON 工作流代码并将其粘贴到您的编辑器 UI 中：

{
"meta": {
	"templateCredsSetupCompleted": true,
	"instanceId": "cb484ba7b742928a2048bf8829668bed5b5ad9787579adea888f05980292a4a7"
},
"nodes": [
	{
	"parameters": {},
	"id": "ed8dc090-ae8c-4db6-a93b-0fa873015c25",
	"name": "When clicking \"Execute workflow\"",
	"type": "n8n-nodes-base.manualTrigger",
	"typeVersion": 1,
	"position": [
		460,
		460
	]
	},
	{
	"parameters": {
		"jsCode": "let urls = [\n  {\n    json: {\n      url: 'https://medium.com/feed/n8n-io'\n    }\n  },\n  {\n   json: {\n     url: 'https://dev.to/feed/n8n'\n   } \n  }\n]\n\nreturn urls;"
	},
	"id": "1df2a9bf-f970-4e04-b906-92dbbc9e8d3a",
	"name": "Code",
	"type": "n8n-nodes-base.code",
	"typeVersion": 2,
	"position": [
		680,
		460
	]
	},
	{
	"parameters": {
		"options": {}
	},
	"id": "3cce249a-0eab-42e2-90e3-dbdf3684e012",
	"name": "Loop Over Items",
	"type": "n8n-nodes-base.splitInBatches",
	"typeVersion": 3,
	"position": [
		900,
		460
	]
	},
	{
	"parameters": {
		"url": "={{ $json.url }}",
		"options": {}
	},
	"id": "50e1c1dc-9a5d-42d3-b7c0-accc31636aa6",
	"name": "RSS Read",
	"type": "n8n-nodes-base.rssFeedRead",
	"typeVersion": 1,
	"position": [
		1120,
		460
	]
	}
],
"connections": {
	"When clicking \"Execute workflow\"": {
	"main": [
		[
		{
			"node": "Code",
			"type": "main",
			"index": 0
		}
		]
	]
	},
	"Code": {
	"main": [
		[
		{
			"node": "Loop Over Items",
			"type": "main",
			"index": 0
		}
		]
	]
	},
	"Loop Over Items": {
	"main": [
		null,
		[
		{
			"node": "RSS Read",
			"type": "main",
			"index": 0
		}
		]
	]
	},
	"RSS Read": {
	"main": [
		[
		{
			"node": "Loop Over Items",
			"type": "main",
			"index": 0
		}
		]
	]
	}
},
"pinData": {}
}