Tạo AI Bất đồng bộ bằng Vòng lặp Thăm dò Replicate - Quy trình làm việc n8n

Lập trình viên & Tích hợp AI: Người dùng cần tích hợp các mô hình AI chạy lâu, bất đồng bộ (như những mô hình được host trên Replicate) vào quy trình nghiệp vụ tiêu chuẩn của họ.
Người dùng n8n Nâng cao: Những cá nhân đang tìm kiếm các ví dụ nâng cao về cách sử dụng Code node của n8n và các cấu trúc điều khiển luồng (If và Wait) để xử lý các API bên ngoài.
Chuyên gia Tự động hóa Nội dung: Bất kỳ ai tìm kiếm các bản mẫu n8n đáng tin cậy để tạo nội dung sáng tạo dựa trên các câu lệnh (prompt).
Người tự động hóa Kỹ thuật: Người dùng cần một cơ chế kích hoạt (trigger) n8n mạnh mẽ để bắt đầu các tác vụ tính toán phức tạp.

Việc tạo nội dung phức tạp thường đòi hỏi chạy các tác vụ một cách bất đồng bộ, nghĩa là yêu cầu ban đầu trả về trạng thái ngay lập tức nhưng kết quả cuối cùng sẽ bị trễ. Luồng công việc n8n mạnh mẽ này giải quyết vấn đề đó bằng cách triển khai một chuỗi thăm dò tùy chỉnh, không chặn (non-blocking) được điều chỉnh riêng cho API của Replicate.

Không giống như các tích hợp đơn giản hơn, bản mẫu n8n này đảm bảo độ tin cậy bằng cách khởi tạo quá trình dự đoán, trích xuất ID tác vụ, và sau đó liên tục kiểm tra trạng thái sau mỗi hai giây cho đến khi tác vụ thành công. Việc sử dụng httpRequest node của n8n, kết hợp với việc xử lý dữ liệu trong Code node của n8n, cung cấp một khuôn khổ mạnh mẽ và có thể tái sử dụng để tích hợp bất kỳ dịch vụ bất đồng bộ nào vào môi trường n8n của bạn. Cấu trúc này là cần thiết để xây dựng các quy trình tự động hóa quan trọng đối với hoạt động (mission-critical) bằng cách sử dụng n8n.

Luồng công việc n8n mạnh mẽ này bắt đầu bằng một trigger thủ công của n8n:

1. Khởi tạo: Luồng công việc được thực thi thủ công thông qua trigger 'On clicking 'execute'' (Khi nhấn 'thực thi') của n8n. Ngay sau đó, node 'Set API Key' (Đặt Khóa API) của n8n sẽ tiêm khóa API Replicate của bạn một cách bảo mật dưới dạng biến cho các yêu cầu HTTP tiếp theo.


2. Bắt đầu Dự đoán: Node 'Create Prediction' (Tạo Dự đoán) của n8n (một Yêu cầu HTTP) gửi yêu cầu POST tới Replicate, chỉ định phiên bản mô hình và câu lệnh đầu vào (prompt) cần thiết. Thao tác này khởi động tác vụ AI bất đồng bộ.


3. Trích xuất: Phản hồi từ yêu cầu tạo chứa ID tác vụ. Code node 'Extract Prediction ID' (Trích xuất ID Dự đoán) của n8n sẽ phân tích cú pháp phản hồi này, lưu trữ ID dự đoán và URL cần thiết cho việc thăm dò.


4. Bước vào Vòng lặp Thăm dò: Quá trình thực thi đi vào vòng lặp thăm dò. Nó chạm vào node 'Wait' (Chờ) của n8n trước tiên, tạm dừng toàn bộ luồng công việc n8n trong 2 giây để tránh các cuộc gọi API quá mức.


5. Kiểm tra Trạng thái: httpRequest node 'Check Prediction Status' (Kiểm tra Trạng thái Dự đoán) của n8n sau đó truy vấn URL dự đoán đã được trích xuất trước đó để lấy trạng thái hiện tại của tác vụ AI.


6. Kiểm tra Điều kiện: If node 'Check If Complete' (Kiểm tra Nếu Hoàn thành) của n8n đánh giá trạng thái. Nếu trạng thái bằng 'succeeded' (thành công) (nhánh True), tác vụ đã hoàn tất và luồng công việc n8n tiến hành xử lý kết quả. Nếu trạng thái là bất cứ thứ gì khác (nhánh False), kết nối sẽ lặp lại trở lại node 'Wait' của n8n, khởi động lại quá trình thăm dò cho đến khi hoàn thành.


7. Xử lý Kết quả: Khi thành công, Code node 'Process Result' (Xử lý Kết quả) của n8n sẽ trích xuất nội dung được tạo cuối cùng (thường là URL trỏ đến tài sản) và định dạng nó gọn gàng để sử dụng ở các bước tiếp theo trong luồng công việc n8n của bạn.

Để sử dụng bản mẫu luồng công việc n8n này, hãy làm theo các bước sau:

1. Nhập (Import): Sao chép mã JSON được cung cấp và nhập trực tiếp vào phiên bản n8n của bạn.


2. Thiết lập Khóa API (Replicate): Tìm node 'Set API Key' (Đặt Khóa API) của n8n.

1. Cấu hình Đầu vào Mô hình: Tìm node 'Create Prediction' (Tạo Dự đoán) của n8n. Trong phần cấu hình JSON Body của nó, sửa đổi giá trị prompt và bất kỳ tham số đầu vào nào khác (như width, height, v.v.) để phù hợp với yêu cầu tạo nội dung mong muốn của bạn. Đảm bảo phiên bản mô hình trong phần thân JSON là chính xác.


2. Thực thi: Chạy luồng công việc n8n thủ công bằng cách sử dụng nút 'Execute Workflow' (Thực thi Luồng công việc) trên node trigger 'On clicking 'execute'' (Khi nhấn 'thực thi') của n8n để kiểm tra tích hợp và vòng lặp thăm dò.

On clicking 'execute' (Kích hoạt Thủ công): Đóng vai trò là trigger khởi đầu cho toàn bộ luồng công việc n8n, cho phép thực thi thủ công để kiểm tra và cấu hình.
Set API Key (Đặt Khóa API) (Set): Một node n8n quan trọng được sử dụng để xác định khóa API Replicate một cách bảo mật, làm cho nó có thể truy cập được dưới dạng một biểu thức ($($Set API Key).item.json.replicateapikey) trong phần còn lại của luồng công việc n8n.
Create Prediction (Tạo Dự đoán) (Yêu cầu HTTP): Gửi yêu cầu POST bất đồng bộ ban đầu tới API Replicate, bắt đầu tác vụ tạo AI. Nó bao gồm các tiêu đề tùy chỉnh để xác thực bằng cách sử dụng khóa API đã được xác định trước đó.
Extract Prediction ID (Trích xuất ID Dự đoán) (Code): Một Code node tùy chỉnh của n8n rất quan trọng để đọc phản hồi từ yêu cầu dự đoán ban đầu. Nó trích xuất predictionId duy nhất và xây dựng URL thăm dò cần thiết cho các yêu cầu tiếp theo trong luồng công việc n8n.
Wait (Chờ) (Wait): Quản lý luồng điều khiển bằng cách tạm dừng luồng công việc n8n trong một khoảng thời gian xác định (2 giây), ngăn chặn các yêu cầu API gọi liên tục trong vòng lặp thăm dò.
Check Prediction Status (Kiểm tra Trạng thái Dự đoán) (Yêu cầu HTTP): Thực hiện một yêu cầu GET bằng cách sử dụng URL dự đoán đã trích xuất để kiểm tra trạng thái của tác vụ AI đang chạy. Đây là bước thăm dò cốt lõi trong bản mẫu n8n này.
Check If Complete (Kiểm tra Nếu Hoàn thành) (If): Một node n8n điều khiển luồng chỉ đạo logic của luồng công việc n8n. Nếu trạng thái là 'succeeded' (thành công), nó sẽ chuyển sang bộ xử lý kết quả; nếu không, nó sẽ quay trở lại node 'Wait' của n8n để tiếp tục thăm dò.
Process Result (Xử lý Kết quả) (Code): Code node n8n cuối cùng chỉ thực thi khi thành công. Nó cấu trúc và trích xuất đầu ra đã hoàn thiện, bao gồm các chỉ số và URL tài sản được tạo ra, làm sạch dữ liệu cho các bước tiếp theo trong luồng công việc n8n lớn hơn của bạn.