Node.js调用Elasticsearch搜索返回空_source字段问题

• 基于Elasticsearch Cloud + Node.js @elastic/elasticsearch客户端搭建服务
• Kibana控制台执行match_all查询可正常返回带完整字段的文档结果
• Node.js侧调用相同查询逻辑，经Postman测试时返回结果的_source字段为空

客户端初始化与索引创建逻辑 #

const { Client } = require('@elastic/elasticsearch');
const { ELASTIC_SEARCH } = require('../config');

// Elastic Search Cloud Client Setup
const elasticClient = new Client({
    cloud: { id: ELASTIC_SEARCH.CLOUDID },
    auth: {
        apiKey: ELASTIC_SEARCH.API_KEY
    }
});


async function prepareIndex() {
const merchantIndexExists = await elasticClient.indices.exists({ index: 'index2' }); 
        if (merchantIndexExists) return;
        await elasticClient.indices.create({
            index: 'index2',
            body: {
                mappings: {
                    dynamic: 'strict',
                    properties: {
                        company_name: { type: 'text' },
                        company_email: { type: 'keyword' },
                        name: { type: 'text' },
                        price: { type: 'scaled_float', scaling_factor: 10 },
                        created_date: { type: 'date' },
                        is_delete: { type: 'boolean', doc_values: false },
                        merchant: { type: 'keyword', index: 'true' }
                    }
                }
            }
        });
  }

文档写入逻辑 #

const { company_name, company_email, price } = req.body;
const response = await elasticClient.index({
    index: 'index2',
    document: {
        company_email,
        company_name,
        price
    }
});

问题搜索逻辑 #

const response = await elasticClient.search({
    index: 'index2',
    query: {
        match_all: {}
    }
});

• 响应结构读取错误：@elastic/elasticsearch客户端7.x和8.x大版本的返回结构存在不兼容变更，7.x版本默认将实际业务返回结果包裹在body字段下；8.x版本默认直接返回业务结果，若开启meta: true配置则又会回到包裹结构。如果读取层级错误，会误将元信息结构当作搜索结果，出现_source为空的错觉。
• API Key权限不足：Node.js使用的API Key配置了字段级安全（FLS）规则，被限制读取索引字段内容，因此返回空_source；Kibana使用管理员权限账号访问，不受该限制所以能返回完整结果。
• 索引创建逻辑bug：现有代码中indices.exists判断逻辑不兼容客户端异常处理规则——索引不存在时该接口会抛出404错误而非返回false，导致索引创建逻辑从未执行，实际写入的index2是ES自动创建的，若命中集群索引模板的_source禁用/字段排除规则，会出现_source为空的问题。
• 版本不兼容：本地安装的@elastic/elasticsearch客户端大版本与Elasticsearch Cloud集群大版本不一致，导致响应反序列化异常，_source字段无法正常解析。

1. 校验响应读取逻辑
   先打印完整的搜索响应对象，确认结果层级：

• 7.x版本客户端需从response.body.hits.hits路径取文档结果
• 8.x版本客户端默认从response.hits.hits取结果，若初始化时配置了meta: true，同样需要从response.body层级取结果
  确认读取层级正确后再返回给前端，避免因解构错误丢失_source内容。

2. 校验API Key权限
   登录Elasticsearch Cloud控制台，检查当前使用的API Key权限配置，移除字段级安全限制，授予该Key对index2的read、view_index_metadata权限。

3. 修复索引创建逻辑，重建索引验证
   修正indices.exists的异常判断逻辑，兼容不同客户端版本的返回格式，同时适配8.x客户端不需要body包裹mappings的参数规则，修复后代码如下：

async function prepareIndex() {
  let merchantIndexExists = false;
  try {
    const existRes = await elasticClient.indices.exists({ index: 'index2' });
    merchantIndexExists = typeof existRes === 'boolean' ? existRes : existRes.statusCode === 200;
  } catch (e) {
    // 索引不存在时接口返回404，捕获后标记为不存在
    if (e?.meta?.statusCode !== 404) throw e;
  }
  if (merchantIndexExists) return;

  await elasticClient.indices.create({
    index: 'index2',
    mappings: {
      dynamic: 'strict',
      properties: {
        company_name: { type: 'text' },
        company_email: { type: 'keyword' },
        name: { type: 'text' },
        price: { type: 'scaled_float', scaling_factor: 10 },
        created_date: { type: 'date' },
        is_delete: { type: 'boolean', doc_values: false },
        merchant: { type: 'keyword' }
      }
    }
  });
}

修复后先删除原有异常的index2索引，重新执行prepareIndex确保mapping正确生效，再写入测试数据验证搜索结果。

4. 对齐客户端与集群版本
   执行npm list @elastic/elasticsearch查看本地客户端版本，保证客户端大版本与Cloud集群大版本完全一致，避免跨版本序列化兼容问题。

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