SvelteKit Stripe Webhook异步操作被终止，如何确保执行？（Cloudflare）

问题 #

在SvelteKit项目中处理Stripe webhook时遇到异常：处理器需在结账会话完成后将客户ID存储至Supabase，但storeStripeCustomerId函数执行到Supabase的upsert操作后便中断，后续日志完全无输出。相关代码如下：

存储客户ID的函数 #

export const storeStripeCustomerId = async (session: Stripe.Checkout.Session) => {
    let customerId: string = '';
    if (typeof session.customer === 'string') {
        customerId = session.customer;
    } else if (session.customer !== null) {
        customerId = session.customer.id;
    }
    console.log("Storing Stripe customer ID", customerId, "for session", session.id);
    if (customerId) {
        // 此处日志可正常输出
        console.log("session.client_reference_id", session.client_reference_id);
        const {error} = await SUPABASE_SERVICE_ROLE.schema('stripe').from('user_id_table').upsert({
            id: session.client_reference_id,
            stripe_customerid: customerId,
            stripe_email: session.customer_details?.email
        });

        // 此处日志无输出，函数执行中断
        console.log("Test");
        console.log(error);
      
        if (error) {
            console.error(error);
            errorReturn(400, "Supabase: " + error.message);
        }
    }
}

Webhook处理器代码 #

// /api/stripe/webhook
...
case 'checkout.session.completed': {
    const session: Stripe.Checkout.Session = event.data.object
    storeStripeCustomerId(session);
    break;
}

核心矛盾：

• 无法用await调用storeStripeCustomerId，需快速向Stripe返回响应避免超时
• 本地运行正常，但部署到Cloudflare后异步操作被提前终止
• 已确认Supabase环境变量正确，Stripe可正常调用webhook

需确保storeStripeCustomerId完整执行完毕，即使webhook已向Stripe返回响应。

解决方案 #

1. 用Cloudflare Worker的waitUntil托管异步任务 #

在Cloudflare部署的SvelteKit项目中，Worker运行时提供waitUntil方法，可让异步任务在响应返回后继续执行。修改webhook路由代码，将异步任务传入waitUntil：

// /api/stripe/webhook
import type { Platform } from '@sveltejs/adapter-cloudflare';

export async function POST({ request, platform }: { request: Request; platform: Platform }) {
    // 验证Stripe签名等前置逻辑...
    const event = stripe.webhooks.constructEvent(...);

    switch (event.type) {
        case 'checkout.session.completed': {
            const session: Stripe.Checkout.Session = event.data.object;
            // 用waitUntil包裹任务，确保响应返回后继续执行
            platform.context.waitUntil(storeStripeCustomerId(session));
            break;
        }
        // 其他事件处理...
    }

    // 快速返回响应给Stripe
    return new Response(JSON.stringify({ received: true }), { status: 200 });
}

2. 优化函数内部错误处理 #

原函数中的errorReturn可能抛出错误中断执行，改为内部捕获并记录错误，避免向外抛出影响任务执行：

export const storeStripeCustomerId = async (session: Stripe.Checkout.Session) => {
    let customerId: string = '';
    if (typeof session.customer === 'string') {
        customerId = session.customer;
    } else if (session.customer !== null) {
        customerId = session.customer.id;
    }
    console.log("Storing Stripe customer ID", customerId, "for session", session.id);
    
    if (!customerId) {
        console.warn("No customer ID found for session", session.id);
        return;
    }

    try {
        console.log("session.client_reference_id", session.client_reference_id);
        const {error} = await SUPABASE_SERVICE_ROLE.schema('stripe').from('user_id_table').upsert({
            id: session.client_reference_id,
            stripe_customerid: customerId,
            stripe_email: session.customer_details?.email
        });

        console.log("Test");
        console.log(error);
      
        if (error) {
            console.error("Supabase upsert error:", error);
        }
    } catch (err) {
        console.error("Unexpected error in storeStripeCustomerId:", err);
    }
}

3. 调整Cloudflare Worker超时设置 #

Cloudflare Worker默认异步任务超时为5秒，若Supabase操作耗时较长，可在Cloudflare控制台将Worker超时时间调整至最大60秒，确保任务有足够时间完成。

4. 验证环境差异 #

本地Node.js环境不会主动终止未等待的异步任务，但Cloudflare Worker在响应返回后会清理未被waitUntil包裹的任务，需确保所有后台执行的异步任务都被waitUntil托管。

内容的提问来源于stack exchange，提问作者Josip Domazet