使用requests向Elasticsearch索引提交文档时遭遇405/406错误的排查求助

我来帮你逐一分析你遇到的问题，结合ES 7.16.3的API规范和requests库的特性，给出具体的解决方案：

为什么直接POST到/my_index会返回405？ #

Elasticsearch的索引根端点/my_index并不接受POST请求，这个端点主要用于索引的创建、查询元数据等操作（比如PUT创建索引，GET查询索引信息）。要创建文档，你必须使用正确的文档操作端点：

• 自动生成文档ID：POST /my_index/_doc
• 指定ID创建（仅当ID不存在时成功）：POST /my_index/_create/<你的文档ID>

直接POST到索引根路径属于方法不允许，所以返回405错误，这是正常的API限制。

为什么POST到/_doc会返回406？ #

406（Not Acceptable）错误通常和请求头的Accept或Content-Type不匹配有关。结合你说Postman/curl能正常操作，大概率是以下两个原因之一：

1. 缺少认证信息：你的ES集群开启了身份验证（比如基础用户名密码认证），Postman和curl里已经配置了认证，但你的requests请求没加，导致ES拒绝返回符合格式的响应。
2. 请求头冲突：当你同时使用json=data参数和手动指定Content-Type头时，requests内部可能会出现头信息重复或冲突的情况。

为什么PUT请求有时返回401/406，有时有效？ #

401（Unauthorized）明确说明请求缺少有效的认证信息，而你那个有效的PUT请求：

response = requests.put(f'http://localhost:9200/my_index/_doc/2', data=json.dumps(data), headers=headers)

能成功是因为：

• 端点和方法正确（PUT /my_index/_doc/<id>用于指定ID的创建/更新）
• 正确设置了Content-Type: application/json头
• 可能你当时的环境中存在认证缓存，或者这个请求刚好通过了ES的安全策略（比如IP白名单）

具体解决方案 #

1. 修正请求端点和方法 #

按照ES规范调整你的请求路径：

# 自动生成ID创建文档
response = requests.post(f'http://localhost:9200/my_index/_doc', json=data, auth=auth)

# 指定ID创建文档（仅当ID不存在时成功）
response = requests.post(f'http://localhost:9200/my_index/_create/3', json=data, auth=auth)

# 指定ID创建或更新文档
response = requests.put(f'http://localhost:9200/my_index/_doc/3', json=data, auth=auth)

2. 添加认证信息 #

既然Postman/curl能正常操作，说明你需要在requests中加入和它们一致的认证参数。如果是基础认证：

from requests.auth import HTTPBasicAuth

# 替换成你的ES用户名和密码
auth = HTTPBasicAuth('elastic', 'your_password')

然后在所有请求中加上auth=auth参数。

3. 规范请求头的使用 #

• 使用json=data参数时，requests会自动设置Content-Type: application/json，不需要手动添加headers，避免冲突：

  response = requests.post(f'http://localhost:9200/my_index/_doc', json=data, auth=auth)
  

• 如果必须用data=json.dumps(data)，则必须手动指定headers：

  headers = {'Content-type': 'application/json'}
  response = requests.post(f'http://localhost:9200/my_index/_doc', data=json.dumps(data), headers=headers, auth=auth)
  

4. 排查406错误的额外手段 #

如果添加认证后还是出现406，可以手动指定Accept头，确保ES返回JSON格式的响应：

headers = {
    'Content-Type': 'application/json',
    'Accept': 'application/json'
}
response = requests.post(f'http://localhost:9200/my_index/_doc', json=data, headers=headers, auth=auth)

同时，你可以打印请求的完整头信息，和Postman的请求头对比，找出差异：

print(response.request.headers)

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