有始有終的 Replicate Webhook。

時限問題

透過 AnyHook 接收 Replicate 的執行完成通知

把 AnyHook 的接收網址（inbound URL）當作預測的 `webhook` 參數傳入。下游的處理程式就有足夠的時間把結果分送出去。

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 });
}

團隊常問的問題

所有 Replicate 模型類型都適用嗎？

適用，圖片、影片、音訊、語言模型都一樣。Webhook 的規格完全相同。AnyHook 把 payload 當成不透明的 JSON，原封不動地轉送。

Replicate 已經會重試了，為什麼還需要 AnyHook？

Replicate 會在傳輸失敗時重試，但時間窗很短，而且它只重試 Webhook 的傳遞，不會重試你下游的商業邏輯。AnyHook 以指數退避重試你的處理程式，Scale 方案最多 10 次，而且只要方案還保存著事件，任何事件按一下就能重播。

不用再回 Replicate 查，也能看到預測的輸出嗎？

可以。完整的 Webhook payload（包括 `output` 網址）都加密儲存在你的 AnyHook 事件紀錄裡：在儀表板開啟，或用 GET /api/v1/events/{id} 讀取。

AnyHook 會驗證 Replicate 的簽章嗎？

會，設定好之後就會。Replicate 用 Standard Webhooks 機制簽章（webhook-id、webhook-timestamp、webhook-signature）。把 App（一個接收網址，對應一個 Webhook 來源）的來源設為 Standard Webhooks，貼上從 Replicate 的 GET /v1/webhooks/default/secret 取得的密鑰：偽造的請求會在邊緣節點被拒收。