Node.js调用Mailchimp API添加列表成员遇400错误，求解决方案

问题背景 #

正在参加Angela Yu的Web开发训练营，开发用户邮件列表订阅应用：用户在页面输入信息提交后，通过Mailchimp API将其加入邮件列表。按官方文档编写代码后，始终返回400状态码，现有代码如下：

const express = require("express");
const bodyParser = require("body-parser");
const request = require('request');
const https = require("https");
const mailchimp = require("@mailchimp/mailchimp_marketing");

const app = express();

app.use(bodyParser.urlencoded({
  extended: true
}));
app.use(express.static("public"));

mailchimp.setConfig({
  apiKey: "7a6374510cc1647147c788b55eb3db8b-us21",
  server: "us21",
});

app.get("/", function(req, res) {
  res.sendFile(__dirname + "/signup.html");
});

app.post("/", function(req, res) {
  const listId = "df58b4dffb";
  const subscribingUser = {
    firstName: req.body.fName,
    lastName: req.body.lName,
    email: req.body.email
  };

  async function run() {
    const response = await mailchimp.lists.addListMember(listId, {
      email_address: subscribingUser.email,
      status: "subscribed",
      merge_fields: {
        FNAME: subscribingUser.firstName,
        LNAME: subscribingUser.lastName
      }
    });

    console.log(
      `Successfully added contact as an audience member. The contact's id is ${
      response.id
    }.`
    );
  }

  run();
});

核心问题与解决步骤 #

• 缺失错误捕获逻辑：原代码未处理API请求的错误，无法获取400错误的具体原因，必须添加try/catch块捕获并输出错误详情，这是排查问题的核心。
• 异步函数未正确处理：run()作为异步函数，原代码未等待其执行完成，也未向客户端返回响应，需将app.post回调改为async，并使用await处理API调用。
• 基础信息验证：确认API密钥、列表ID完全正确，API密钥后缀需与server字段匹配；检查HTML表单的name属性是否与后端req.body接收的字段名（fName、lName、email）一致，避免字段为空触发错误。
• 合并字段匹配：验证Mailchimp受众设置中的合并字段是否为FNAME和LNAME，自定义字段需对应修改merge_fields中的键名。

修正后的完整代码 #

const express = require("express");
const bodyParser = require("body-parser");
const mailchimp = require("@mailchimp/mailchimp_marketing");

const app = express();

app.use(bodyParser.urlencoded({ extended: true }));
app.use(express.static("public"));

mailchimp.setConfig({
  apiKey: "7a6374510cc1647147c788b55eb3db8b-us21",
  server: "us21",
});

app.get("/", function(req, res) {
  res.sendFile(__dirname + "/signup.html");
});

// 将post回调改为async，支持await
app.post("/", async function(req, res) {
  const listId = "df58b4dffb";
  const subscribingUser = {
    firstName: req.body.fName,
    lastName: req.body.lName,
    email: req.body.email
  };

  try {
    const response = await mailchimp.lists.addListMember(listId, {
      email_address: subscribingUser.email,
      status: "subscribed",
      merge_fields: {
        FNAME: subscribingUser.firstName,
        LNAME: subscribingUser.lastName
      }
    });

    console.log(`Successfully added contact. ID: ${response.id}`);
    res.sendFile(__dirname + "/success.html"); // 替换为你的成功页面路径
  } catch (error) {
    // 输出详细错误信息，便于定位问题
    console.error("Error details:", error.response.body);
    res.sendFile(__dirname + "/failure.html"); // 替换为你的失败页面路径
  }
});

// 启动服务器，根据需求修改端口
app.listen(3000, function() {
  console.log("Server running on port 3000");
});

额外排查要点 #

• 验证用户输入的邮箱格式是否合法，Mailchimp会拒绝无效邮箱返回400错误。
• 确认API密钥拥有受众管理的权限，避免权限不足导致请求失败。

内容的提问来源于stack exchange，提问作者gaurav jha