使用Stripe API遇异步问题：await报错及避免回调地狱方案咨询

你的问题核心有两个：一是**await必须在async函数内使用**，二是异步操作的依赖顺序没处理好（创建Plan时需要先用Product的ID，但Product还没创建完成）。下面是一套清晰的解决方案，完全避免回调地狱，同时符合Node.js/Stripe的最佳实践：

关键修正步骤 #

1. 给外层函数添加async关键字 #

Node.js报错的直接原因是你在非async函数里使用了await。如果这是一个Express路由处理函数（从文件路径routes/payment.js推测），直接给函数加上async标记即可：

// 示例：Express路由处理函数，添加async
app.post('/process-payment', async (req, res) => {
  // 所有逻辑放在这里
});

2. 用await按顺序处理所有异步操作 #

Stripe的所有API方法都返回Promise，用await可以让代码按同步逻辑的顺序执行，完美避免回调地狱。同时要修正createPlan里的Product参数——你原来的代码硬编码了字符串，应该用创建完成后的Product ID。

3. 修正变量声明与错误判断 #

• 用let/const替代var，避免变量提升问题；
• 修正typeof的判断逻辑：typeof返回的是字符串，所以要和'undefined'比较，而不是undefined。

完整修正后的代码 #

// 假设这是你的Express路由处理函数
app.post('/process-payment', async (req, res) => {
  try {
    // 1. 先创建Product，await确保操作完成
    const product = await stripe.products.create({
      name: 'DigitLead website evaluation tool monthly charge',
      type: 'service',
    });

    // 2. 定义创建Plan的函数（可选，也可以直接内联）
    const createPlan = async (amount) => {
      return stripe.plans.create({
        product: product.id, // 使用刚创建的Product ID
        nickname: 'DigitLead website evaluation tool monthly charge',
        currency: 'cad',
        interval: 'month',
        amount: amount,
      });
    };

    let amount, days, plan;
    const time = req.body.time; // 假设time来自请求参数，根据你的实际场景调整

    // 3. 根据time参数创建对应的Plan
    if (time === '1') {
      amount = 1499;
      days = 30;
      plan = await createPlan(amount);
    } else if (time === '3') {
      amount = 999 * 3;
      days = 90;
      plan = await createPlan(999);
    }

    console.log('Created Plan:', plan);

    // 4. 创建Customer（如果用户还没有Stripe ID）
    if (typeof req.user.stripeId === 'undefined') {
      const customer = await stripe.customers.create({
        email: req.user.username,
        source: req.body.stripeToken,
      });
      // 这里建议把customer.id保存到用户数据库，比如：
      // await User.findByIdAndUpdate(req.user._id, { stripeId: customer.id });
      console.log('Created Customer:', customer);
    }

    // 5. 返回成功响应给前端
    res.status(200).json({ success: true, plan });
  } catch (error) {
    // 统一处理所有错误（Stripe API错误、运行时错误等）
    console.error('Payment processing error:', error);
    res.status(500).json({ error: error.message });
  }
});

为什么这样有效？ #

• async/await消除回调地狱：代码逻辑按顺序执行，可读性极强，比Promise链式调用更直观；
• 确保依赖顺序：先await创建Product，再用它的ID创建Plan，彻底解决“Product未就绪”的问题；
• 错误集中处理：用try/catch包裹所有异步操作，任何环节出错都能被捕获并处理，避免程序崩溃；
• 符合Stripe最佳实践：Stripe官方推荐用async/await处理异步API调用，代码更简洁易维护。

内容的提问来源于stack exchange，提问作者Alex Ironside