Vòng lặp thăm dò tạo AI bất đồng bộ với Replicate - Quy trình làm việc n8n

• Các nhà phát triển AI hoặc người sáng tạo nội dung sử dụng mô hình Replicate cho các tác vụ tạo sinh kéo dài.


• Người dùng đang tìm kiếm một mẫu workflow n8n đáng tin cậy để xử lý các lệnh gọi API bất đồng bộ.


• Các chuyên gia tự động hóa cần triển khai logic điều khiển luồng cốt lõi mạnh mẽ, bao gồm cả vòng lặp thăm dò, trong n8n.

Việc xử lý các tác vụ chạy lâu trong tự động hóa, chẳng hạn như tạo mô hình AI phức tạp, đòi hỏi logic bất đồng bộ. Workflow n8n cụ thể này giải quyết thách thức chung là phải chờ đợi một dịch vụ bên ngoài (Replicate) mà không làm treo toàn bộ quá trình thực thi. Bằng cách sử dụng vòng lặp (loop) của node n8n, mẫu n8n này khởi tạo quá trình tạo sinh mô hình Dessix Moss-TTSD (hoặc tương tự) và sau đó đi vào chuỗi thăm dò (polling sequence). Phương pháp này, cốt lõi trong việc triển khai n8n chuyên nghiệp, đảm bảo tài nguyên không bị lãng phí và workflow chỉ tiếp tục khi quy trình bên ngoài trả về trạng thái thành công. Việc kiểm soát luồng logic cốt lõi này là một tính năng mạnh mẽ của nền tảng n8n, làm cho workflow n8n này có thể tái sử dụng cao cho bất kỳ API nào phụ thuộc vào xử lý nền.

Tự động hóa này bắt đầu bằng trigger n8n 'On clicking 'execute'' (Khi nhấp vào 'thực thi'), được thiết kế để kiểm tra thủ công hoặc thực thi theo lịch trình.

1. Khởi tạo: Workflow đầu tiên sử dụng một node n8n để thiết lập khóa API Replicate một cách an toàn dưới dạng biến có thể tái sử dụng.


2. Tạo Dự đoán (Prediction Creation): Một node n8n HTTP Request gửi yêu cầu POST tới API Replicate để khởi tạo tác vụ tạo AI (sử dụng phiên bản mô hình cụ thể).


3. Trích xuất ID: Một node n8n Code, 'Extract Prediction ID' (Trích xuất ID Dự đoán), phân tích cú pháp phản hồi API ban đầu để lấy ra predictionId duy nhất và xây dựng URL cần thiết cho việc thăm dò.


4. Bắt đầu Thăm dò & Chờ: Workflow đi vào vòng lặp bất đồng bộ thông qua node n8n 'Wait' (Chờ), tạm dừng thực thi trong 2 giây để tránh các lệnh gọi API quá mức.


5. Kiểm tra Trạng thái: Một node n8n HTTP Request khác, 'Check Prediction Status' (Kiểm tra Trạng thái Dự đoán), truy xuất trạng thái tác vụ hiện tại bằng cách sử dụng URL dự đoán đã trích xuất và khóa API.


6. Kiểm tra Điều kiện (Logic Điều khiển Luồng Cốt lõi): Một node n8n If xác định xem trạng thái tác vụ có phải là 'succeeded' (thành công) hay không. Nếu không, workflow sẽ đi theo đường dẫn FALSE và quay lại node n8n 'Wait', khởi động lại chu kỳ thăm dò. Vòng lặp này là trái tim của workflow n8n bất đồng bộ.


7. Xử lý Kết quả: Nếu tác vụ thành công, workflow đi theo đường dẫn TRUE tới node n8n Code 'Process Result' (Xử lý Kết quả), node này sẽ làm sạch và cấu trúc kết quả đầu ra cuối cùng, thường cung cấp URL tài sản kết quả (ví dụ: tệp âm thanh hoặc đầu ra văn bản).

Để sử dụng workflow n8n hiệu quả cao 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 và nhập trực tiếp vào phiên bản n8n của bạn thông qua mục 'Workflows' bằng cách sử dụng nút 'New' (Mới) và chọn 'Import from JSON' (Nhập từ JSON).


2. Thiết lập Chứng chỉ (Credentials): Mẫu n8n này sử dụng chiến lược xác thực HTTP Header chung, nhưng khóa API được đặt bên trong node n8n 'Set API Key' (Thiết lập Khóa API).


3. Cấu hình Khóa API: Mở node n8n 'Set API Key' và thay thế mã giữ chỗ YOURREPLICATEAPIKEY bằng khóa API Replicate thực tế của bạn. Đảm bảo khóa này được thêm tiền tố 'Bearer ' trong các định nghĩa HTTP Header của các node HTTP Request tiếp theo, như được xác định trong biểu thức: ={{ 'Bearer ' + $('Set API Key').item.json.replicateapi_key }}.


4. Kiểm tra: Thực thi workflow n8n thủ công bằng nút 'Execute Workflow' (Thực thi Workflow) để xác minh logic thăm dò và kết nối API.

On clicking 'execute' (trigger n8n): Điểm bắt đầu của workflow n8n. Đây là một trigger thủ công được sử dụng để khởi tạo quy trình tạo sinh cho mục đích trình diễn và kiểm thử.
Set API Key (node n8n): Thiết yếu cho bảo mật. Nó định nghĩa biến replicateapikey, giúp các node HTTP Request tiếp theo truy cập khóa API một cách dễ dàng thông qua các biểu thức.
Create Prediction (node n8n HTTP Request): Khởi tạo tác vụ chạy lâu bằng cách gửi yêu cầu POST. Nó sử dụng API Replicate và bao gồm phiên bản mô hình cùng các tham số đầu vào cần thiết.
Extract Prediction ID (node n8n Code): Phân tích cú pháp phản hồi JSON ban đầu để tách ra id quan trọng của dự đoán, thứ cần thiết cho việc giám sát trạng thái. Node n8n tùy chỉnh này chuẩn bị cấu trúc dữ liệu cho vòng lặp thăm dò.
Wait (node n8n): Triển khai độ trễ cần thiết (2 giây) trong vòng lặp thăm dò, ngăn chặn các vấn đề giới hạn tốc độ (rate-limiting) với API bên ngoài trong khi chờ AI tạo xong. Đây là chìa khóa cho một workflow n8n ổn định.
Check Prediction Status (node n8n HTTP Request): Được gọi lặp đi lặp lại trong vòng lặp thăm dò bằng cách sử dụng URL dự đoán có được từ các bước trước. Nó truy xuất trạng thái hiện tại của tác vụ AI.

• Check If Complete (node n8n If): Cổng kiểm soát logic cốt lõi. Nó kiểm tra xem $json.status có bằng 'succeeded' hay không. Nếu không, luồng sẽ quay lại node n8n 'Wait'. Nếu đúng, workflow n8n sẽ tiếp tục xử lý đầu ra cuối cùng.