能把事情做完的 Replicate Webhook。

时限问题

通过 AnyHook 接收 Replicate 运行完成回调

创建预测时，把 AnyHook 的接收 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 把请求体当作不透明的 JSON，原样转发。

Replicate 已经有重试了，为什么还需要 AnyHook？

Replicate 会在传输失败时重试，但它的时间窗口很短，而且只重试 Webhook 投递，不会重试你的下游业务逻辑。AnyHook 按指数退避重试你的处理程序，Scale 套餐最多 10 次；只要你的套餐还保留着某个事件，就可以一键重放它。

不回 Replicate 查，也能看到预测输出吗？

可以。完整的 Webhook 请求体（包括 `output` 里的 URL）都加密保存在你的 AnyHook 事件日志里：在控制台打开，或者用 GET /api/v1/events/{id} 读取。

AnyHook 会验证 Replicate 的签名吗？

会，前提是你完成了设置。Replicate 使用 Standard Webhooks 签名方案（webhook-id、webhook-timestamp、webhook-signature）。把 App 的来源设为 Standard Webhooks，粘贴从 Replicate 的 GET /v1/webhooks/default/secret 拿到的密钥：伪造的请求会在边缘节点被拒收。