为何searchResult.TotalHits()与len(searchResult.Hits.Hits)结果不一致？

你遇到的这个情况完全是正常的——Elasticsearch（以及对应的Golang客户端）默认单次查询只返回10条结果，这是ES内置的分页保护机制，防止一次性返回海量数据拖垮集群或客户端。TotalHits()返回的是符合查询条件的总文档数，而searchResult.Hits.Hits只包含当前页的结果，默认页大小就是10。

根据你的需求，有两种常见的处理方式：

1. 直接调整单次返回的结果数量 #

如果你的总命中数不算特别大（比如小于10000），可以直接用Size()方法指定单次返回的最大条数。修改你的查询代码即可：

searchResult, err = client.Search().
    Index("index").
    Query(query).
    Pretty(true).
    Size(1000) // 这里设置你需要的页大小，比如1000，不超过ES默认的10000限制
    .Do(ctx)

注意：ES默认有个index.max_result_window参数，默认值是10000，如果你设置的Size超过这个值，会收到报错。如果必须返回超过10000条数据，要么修改这个集群参数（不推荐，可能影响性能），要么用下面的滚动查询。

2. 使用滚动查询（Scroll API）处理大量结果 #

当总命中数很大时，滚动查询是更优的方案——它会创建一个临时的快照，分批返回所有结果，避免一次性加载大量数据到内存。示例代码如下：

import (
    "context"
    "io"
    "log"
    "encoding/json"
)

// 初始化滚动查询，设置过期时间（比如1分钟）和单次返回条数
scroll := client.Scroll("index").
    Query(query).
    Size(100). // 每批返回100条
    Scroll("1m")

defer scroll.Clear(ctx) // 记得清理滚动上下文，避免资源泄漏

for {
    searchResult, err := scroll.Do(ctx)
    if err == io.EOF {
        break // 没有更多结果了，退出循环
    }
    if err != nil {
        // 处理错误
        log.Fatalf("滚动查询出错: %v", err)
    }

    // 处理当前批次的结果
    fmt.Printf("当前批次拿到 %d 条数据\n", len(searchResult.Hits.Hits))
    for _, hit := range searchResult.Hits.Hits {
        var tweet Tweet
        if err := json.Unmarshal(*hit.Source, &tweet); err != nil {
            log.Printf("解析文档失败: %v", err)
            continue
        }
        fmt.Printf("entity: %s\n", tweet)
    }
}

• TotalHits()是符合条件的总文档数，searchResult.Hits.Hits是当前页的结果，两者的差异就是分页机制导致的
• 小数据量场景：直接用Size()调整单次返回的条数即可
• 大数据量场景：优先使用Scroll API分批获取，避免内存过载

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