Elasticsearch _bulk返回空字典

Question

我在ES7.8集群上有一个奇怪的行为，当使用elasticsearch.helpers.streaming_bulk插入数据时，它会显示这个奇怪的错误：

  File "./lib/python2.7/site-packages/elasticsearch/helpers/__init__.py", line 193, in streaming_bulk
    raise_on_error, *args, **kwargs)
  File "./lib/python2.7/site-packages/elasticsearch/helpers/__init__.py", line 124, in _process_bulk_chunk
    for data, (op_type, item) in zip(bulk_data, map(methodcaller('popitem'), resp['items'])):
KeyError: u'items'

为了进行调试，我在return之前向perform_request添加了一行代码，如下所示：

def perform_request(...):
    print(response.status, response.getheaders(), raw_data)
    return response.status, response.getheaders(), raw_data

在日志中它显示：

200 HTTPHeaderDict({'content-length': '2', 'content-type': 'application/json; charset=UTF-8'}) {}

这看起来真的很糟糕。当仔细比较输入和实际ES文档时，我发现有50%的概率数据被成功写入索引，而另外50%的概率失败。

为什么ES7.8群集返回空响应并向下中断所有内容？我如何进一步调试它？

Answer 1

事实证明这是我自己的愚蠢。我在批量请求期间一直指定了filter_path=['hits.hits._id'])参数。

谢谢你的提示@Val。