ElasticSearch中msearch()如何指定q、size、search_type参数实现批量查询

你之前在search()方法中使用的三个快捷参数，在msearch()中按以下规则映射即可：

• search_type：属于请求级通用参数，直接作为msearch()的顶层入参传入即可，对批量请求里的所有子查询生效；如果需要给单个子查询单独配置，也可以写到对应子查询的头行元信息里。
• q：search()里的q是query_string简易查询的快捷传参，在msearch的子查询请求体里，需要写到query.query_string.query字段下。
• size：属于查询体的基础配置参数，直接写在对应子查询的请求体顶层即可。

代码示例 #

你之前的单个查询写法：

es.search(index='my_index', q=query, size=5, search_type='dfs_query_then_fetch')

对应批量查询的msearch实现写法：

# 待批量执行的查询字符串列表
query_list = ["你的第一个查询词", "你的第二个查询词", "你的第三个查询词"]
msearch_body = []
for single_q in query_list:
    # 每对子查询的第一行是头行，写入索引等元信息
    msearch_body.append({"index": "my_index"})
    # 每对子查询的第二行是请求体，映射q、size参数
    msearch_body.append({
        "query": {
            "query_string": {
                "query": single_q
            }
        },
        "size": 5
    })

# 发起msearch请求，search_type作为顶层参数传入
response = es.msearch(
    body=msearch_body,
    search_type="dfs_query_then_fetch"
)

注意：msearch的请求体是NDJSON格式，必须严格按照「头行、体行」的顺序成对拼接，不能缺行。如果单个子查询需要自定义独立的size、search_type配置，直接在对应子查询的头/体行里写入对应字段即可，会覆盖顶层传入的默认配置。

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