向ElasticSearch提交动态对象数组时出现字段显示异常问题

兄弟，你这个问题我太熟了——这是没摸透Elasticsearch批量API（_bulk）的格式要求导致的！当你提交单个对象时，用的是单文档索引接口，格式没问题；但提交数组时，必须严格遵循**「操作元数据+文档内容」交替出现**的规则，不然ES会把整个数组当成单个文档的字符串化字段来处理。

先给你看正确的批量提交格式 #

Elasticsearch的bulk接口要求请求体是一个数组，每两个元素为一组：第一个是操作元数据（指定_index、_type等），第二个是对应的文档内容。多文档就重复这个组合。

修正后的代码示例如下：

const elasticsearch = require('elasticsearch');
// 记得配置你的ES服务地址哦
const client = new elasticsearch.Client({ host: 'localhost:9200' });

// 正确的bulk请求体：交替的操作元数据和文档
const bodyMsg = [
  // 第一个文档的操作配置
  { index: { _index: 'logs-2018.04.09', _type: 'log', pipeline: null } },
  // 第一个文档的实际内容
  { '@timestamp': '2018-04-09T12:17:17.645Z', message: 'logmessage1', severity: 'info', fields: { temp: 25 } },
  // 第二个文档的操作配置
  { index: { _index: 'logs-2018.04.09', _type: 'log', pipeline: null } },
  // 第二个文档的实际内容
  { '@timestamp': '2018-04-09T12:17:18.123Z', message: 'logmessage2', severity: 'warn', fields: { temp: 30 } }
];

// 执行批量提交
client.bulk({ body: bodyMsg })
  .then(res => console.log('批量提交成功:', res))
  .catch(err => console.error('批量提交失败:', err));

动态生成批量请求体的小技巧 #

如果你的文档数组是动态获取的（比如从数据库、日志文件读取），可以用Array.flatMap快速转换成符合要求的格式，不用手动一个个写：

// 假设这是你的原始文档数组
const rawLogs = [
  { '@timestamp': '2018-04-09T12:17:17.645Z', message: 'logmessage1', severity: 'info', fields: { temp: 25 } },
  { '@timestamp': '2018-04-09T12:17:18.123Z', message: 'logmessage2', severity: 'warn', fields: { temp: 30 } }
];

// 一键转换成bulk要求的格式
const bodyMsg = rawLogs.flatMap(log => [
  { index: { _index: 'logs-2018.04.09', _type: 'log', pipeline: null } },
  log
]);

验证结果 #

提交完成后，你可以用ES的查询接口验证：

GET logs-2018.04.09/_search

就能看到每个文档都被正确索引，所有字段都会正常显示啦！

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