Khôi phục Dữ liệu bằng itemMatching() trong Node Code - Quy trình làm việc n8n

Automation này lý tưởng cho:
Các nhà phát triển n8n đang học các kỹ thuật scripting nâng cao.
Người dùng cần các phương pháp đáng tin cậy để bảo toàn nguồn gốc dữ liệu (data lineage) xuyên suốt các workflow n8n phức tạp.
Các kỹ sư xây dựng các template n8n theo dạng module mà tại đó chỉ số mục (item indices) cần được duy trì để tương quan dữ liệu.
Bất kỳ ai tìm kiếm sự hiểu biết sâu sắc hơn về thao tác dữ liệu trong ngữ cảnh thực thi của n8n.

Khi xây dựng các workflow n8n phức tạp, bạn thường cần biến đổi hoặc lọc các luồng dữ liệu, điều này đôi khi dẫn đến việc mất tạm thời các trường gốc (như email hoặc ID). Workflow n8n cụ thể này cung cấp một giải pháp mạnh mẽ bằng cách sử dụng hàm itemMatching() tích hợp sẵn có trong node Code của n8n.

The value of this n8n automation is in ensuring data integrity. Nó mô phỏng một kịch bản trong đó dữ liệu ban đầu được tạo ra, sau đó bị cắt giảm mạnh (chỉ giữ lại tên), và cuối cùng, địa chỉ email gốc được truy xuất và khôi phục chính xác bằng cách sử dụng tương quan chỉ số mục. Phương pháp này rất quan trọng đối với việc thao tác dữ liệu nâng cao và thể hiện một trong những tính năng mạnh mẽ nhất có sẵn trong môi trường scripting của n8n để liên kết các mục dữ liệu qua các giai đoạn khác nhau của workflow n8n.

Workflow n8n này hoạt động qua bốn giai đoạn riêng biệt:

1. Khởi tạo (Manual Trigger): Trigger của n8n bắt đầu quy trình khi người dùng nhấp vào 'Execute Workflow'.


2. Tạo Dữ liệu: Node n8n Customer Datastore (n8n training) tạo ra một danh sách các bản ghi khách hàng mẫu, bao gồm tên và địa chỉ email. Điều này thiết lập luồng dữ liệu ban đầu.


3. Giảm thiểu Dữ liệu: Node n8n Edit Fields (Set) cố tình loại bỏ tất cả các trường ngoại trừ tên khách hàng. Điều này mô phỏng một kịch bản phổ biến nơi dữ liệu được tinh gọn, và ngữ cảnh ban đầu dường như bị mất.


4. Khôi phục Dữ liệu (Node Code): Node n8n cuối cùng, một node Code Python, thực thi logic cốt lõi. Nó lặp qua các mục dữ liệu đã được giảm thiểu. Đối với mỗi mục, nó sử dụng phương thức itemMatching(i), tham chiếu đến dữ liệu gốc đầu ra từ node n8n 'Customer Datastore', để truy xuất địa chỉ email tương ứng dựa trên chỉ số i. Email được truy xuất này sau đó được đính kèm lại vào mục hiện tại dưới một trường mới có tên là restoreEmail. Kỹ thuật mạnh mẽ này đảm bảo tính nhất quán của dữ liệu xuyên suốt workflow n8n.

Để triển khai template n8n này, hãy làm theo các bước sau:

1. Nhập Workflow n8n: Sao chép mã JSON được cung cấp.


2. Mở phiên bản n8n của bạn và điều hướng đến mục 'Workflows'.


3. Nhấp vào 'New' hoặc 'Import from JSON' và dán mã.


4. Thực thi: Vì workflow n8n này sử dụng trigger n8n thủ công và các node dữ liệu giả (cho mục đích đào tạo), nên không yêu cầu bất kỳ thông tin xác thực bên ngoài nào.


5. Nhấp vào nút 'Execute Workflow' trên node n8n 'When clicking "Execute Workflow"' để xem logic khớp mục (item matching) hoạt động. Xem lại đầu ra của node Code n8n cuối cùng để xác nhận các địa chỉ email đã được khôi phục thành công.

Workflow n8n này tận dụng các loại node n8n chính sau:

When clicking "Execute Workflow" (Manual Trigger):
Chức năng: Hoạt động như trigger n8n khởi động cho việc kiểm thử và phát triển.
Cấu hình Chính: Không yêu cầu cấu hình; khởi động workflow n8n khi có yêu cầu.

Customer Datastore (n8n training):
Chức năng: Tạo dữ liệu mẫu (khách hàng với tên và email) để cung cấp luồng dữ liệu nguồn.
Cấu hình Chính: Thao tác (Operation) được đặt thành getAllPeople, với returnAll được chọn.

Edit Fields (Set):
Chức năng: Node n8n này thực hiện biến đổi dữ liệu, giảm thiểu các mục đầu vào để chỉ giữ lại trường 'name'. Điều này mô phỏng kịch bản mất dữ liệu mà chúng ta dự định khắc phục.
Cấu hình Chính: Chỉ bao gồm trường name, đặt tùy chọn đầu vào thành none để loại bỏ tất cả các trường khác.

Code (Python):
Chức năng: Node n8n quan trọng nơi phương thức itemMatching() được sử dụng. Nó tương quan chỉ số mục hiện tại với chỉ số gốc từ 'Customer Datastore' để lấy email gốc.
Cấu hình Chính: Sử dụng logic Python:

for i,item in enumerate(input.all()):
          input.all()[i].json.restoreEmail = ('Customer Datastore (n8n training)').itemMatching(i).json.email
        return input.all();