Elasticsearch插入DataFrame遇mapper_parsing_exception，如何获取详细错误信息？

方法1：捕获异常提取完整错误详情 #

直接捕获BadRequestError，通过异常对象的info属性可以拿到ES返回的完整错误响应，里面会明确指出哪个字段解析失败：

from elasticsearch import BadRequestError

try:
    # 注意把Series转成字典，避免潜在的类型问题
    res = es.index(index="test", id=1, document=df.iloc[0].to_dict(), error_trace=True)
except BadRequestError as e:
    # 打印完整错误结构
    print("完整错误详情：")
    print(e.info['error'])
    # 提取根因，通常会直接点名出错字段
    if 'root_cause' in e.info['error']:
        for cause in e.info['error']['root_cause']:
            print(f"具体错误：{cause['reason']}")

举个例子，如果是PLZ字段因为存了NaN（浮点类型）无法匹配ES的integer映射，错误信息会显示：failed to parse field [PLZ] of type [integer] in document with id '1'. Preview of field's value: 'NaN'

方法2：检查DataFrame数据类型与ES映射匹配 #

大部分解析错误都是数据类型不匹配导致的：

• 比如ES映射里PLZ是integer，但DataFrame中该列是float（因为空值被自动转成了NaN）
• 先检查数据类型，再做针对性转换：

# 查看各列数据类型
print(df.dtypes)
# 处理PLZ列的空值并转为整数
df['PLZ'] = df['PLZ'].fillna(0).astype(int)

方法3：批量插入时查看失败详情 #

如果后续用批量插入，也可以关闭raise_on_error，直接获取失败文档的错误信息：

from elasticsearch.helpers import bulk

# 构造批量插入的动作列表
actions = [
    {
        "_index": "test",
        "_id": idx,
        "_source": row.to_dict()
    }
    for idx, row in df.iterrows()
]

# 执行批量插入，不直接抛出异常
success_count, failed_items = bulk(es, actions, raise_on_error=False)

# 打印所有失败的详细信息
for item in failed_items:
    doc_id = item['index']['_id']
    error_msg = item['index']['error']
    print(f"文档ID {doc_id} 插入失败：{error_msg}")

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