Node.js通过axios向Elasticsearch写入数据报400错误如何解决

Node.js环境下使用axios向Elasticsearch导入数据时触发400 Bad Request错误，已提前创建名为sales-enable-data的索引，写入数据时持续抛出请求异常。

app.get("/import/data", async (req, res) => {
  const current = {
    project_name: "java",
    delivery_manager: "Yawhe",
    project_manager: "Ruth",
  };
  const data = JSON.stringify(current);

  await axios({
    url: "http://localhost:9200/sales-enable-data-index/_doc",
    method: "POST",
    headers: {
      "Content-Type": "application/json",
    },
    auth: {
      username: "username",
      password: "password",
    },
    body: data,
  })
    .then((response) => {
      return res.status(200).send(response);
    })
    .catch((err) => {
      return res.status(500).send(err);
    });
});

{
  "code": "ERR_BAD_REQUEST",
  "status": 400
}

• 索引名不匹配：代码请求路径中写的索引是sales-enable-data-index，和提前创建的sales-enable-data名称不一致，后缀多了-index
• axios配置字段错误：axios发起请求时传递请求体的合法字段是data，不是Node.js原生http模块使用的body字段，实际发往ES的请求没有携带有效JSON载荷，ES解析请求参数失败直接返回400
• 认证信息为占位值：代码中auth字段的账号密码是占位字符串，如果ES开启了安全认证，未替换为真实值会额外触发401认证错误

修复后可正常运行的代码如下：

app.get("/import/data", async (req, res) => {
  const current = {
    project_name: "java",
    delivery_manager: "Yawhe",
    project_manager: "Ruth",
  };

  await axios({
    url: "http://localhost:9200/sales-enable-data/_doc",
    method: "POST",
    headers: {
      "Content-Type": "application/json",
    },
    auth: {
      username: "替换为实际ES账号",
      password: "替换为实际ES密码",
    },
    data: current,
  })
    .then((response) => {
      return res.status(200).send(response.data);
    })
    .catch((err) => {
      // 打印ES返回的具体错误信息，方便后续排查字段映射、格式类问题
      console.log("ES写入错误详情：", err.response?.data);
      return res.status(500).send(err.message);
    });
});

核心修改点：

• 修正请求URL中的索引名，和提前创建的sales-enable-data保持一致
• 把axios配置中的body字段替换为官方要求的data字段传递请求体，axios会自动对传入的JS对象做JSON序列化，无需手动调用JSON.stringify
• 将auth配置中的占位账号密码替换为Elasticsearch集群实际的认证信息
• 错误捕获逻辑增加ES原生错误信息打印，后续出现字段类型不匹配、映射冲突等问题时可直接定位根因

内容的提问来源于stack exchange，提问作者Ramya Ramaradjou