Webhook Replicate làm trọn việc đã bắt đầu.

Bài toán thời gian

Callback lượt chạy hoàn tất của Replicate qua AnyHook

Truyền URL nhận (inbound URL) của AnyHook vào tham số `webhook` của prediction. Handler của bạn ở downstream có đủ thời gian cần thiết để fan-out (gửi một sự kiện tới nhiều đích).

import Replicate from "replicate";
import { verifyWebhook } from "anyhook-verify";

const replicate = new Replicate();

// 1. Start the prediction with AnyHook as the callback target.
await replicate.predictions.create({
  version: "...",
  input: { prompt: "..." },
  webhook: `https://in.anyhook.net/${userSlug}/${appSlug}`,
  webhook_events_filter: ["completed"],
});

// 2. Handler, runs after AnyHook has already acked Replicate.
export async function POST(req: Request) {
  if (!(await verifyWebhook(req, process.env.ANYHOOK_SIGNING_SECRET!))) {
    return new Response("invalid", { status: 401 });
  }

  const { id, output } = await req.json();
  await persistOutput(id, output);   //  3s
  await notifyUser(id);              //  2s
  await chainNextModel(output);      // 45s, inside even Free's 60s
  return new Response("ok", { status: 200 });
}

Câu hỏi các team thường đặt ra

Cách này có dùng được với mọi loại mô hình trên Replicate không?

Có: hình ảnh, video, âm thanh, ngôn ngữ. Cơ chế webhook giống hệt nhau. AnyHook coi payload là một khối JSON nguyên vẹn, không đọc bên trong, và chuyển tiếp đúng như vậy.

Replicate đã có cơ chế thử lại. Sao tôi còn cần AnyHook?

Replicate thử lại khi lỗi ở tầng truyền tải, nhưng thời hạn ngắn và nó không thử lại logic nghiệp vụ downstream của bạn, chỉ thử lại lượt gửi webhook. AnyHook thử lại handler của bạn theo exponential backoff (khoảng chờ tăng theo cấp số nhân), tối đa 10 lần trên gói Scale, và phát lại (replay) bất kỳ sự kiện nào bằng một cú bấm trong thời gian gói của bạn còn giữ nó.

Tôi có xem được output của prediction mà không cần vào lại Replicate không?

Có. Toàn bộ payload webhook, gồm cả các URL `output`, được lưu mã hóa trong nhật ký sự kiện AnyHook của bạn: mở nó trong dashboard, hoặc đọc bằng GET /api/v1/events/{id}.

AnyHook có xác minh chữ ký của Replicate không?

Có, sau khi bạn thiết lập. Replicate ký theo cơ chế Standard Webhooks (webhook-id, webhook-timestamp, webhook-signature). Đặt nguồn của App (một URL nhận cho một nguồn webhook, ví dụ “Stripe production”) là Standard Webhooks và dán secret lấy từ GET /v1/webhooks/default/secret của Replicate: request giả mạo bị từ chối tại edge.