使用AsyncElasticsearch跨索引查询文档时遭遇CORS错误

核心问题原因 #

Elasticsearch的getAPI（也就是你用的client.get()）不支持索引通配符，它要求必须指定单个具体的索引名称。当你传入some_index*这类模式时，ES会返回非法请求的错误，若你的代码是通过浏览器前端触发（或后端未正确处理错误转发），就会表现为CORS报错，同时自然无法返回文档。

解决步骤 #

1. 先匹配通配符对应的实际索引 #

先调用ES的索引查询API，获取通配符匹配到的所有具体索引：

# 获取匹配通配符的索引列表
indices_response = await client.cat.indices(index="some_index*", format="json")
target_indices = [item["index"] for item in indices_response]

或者用indices.getAPI：

indices_response = await client.indices.get(index="some_index*")
target_indices = list(indices_response.keys())

2. 遍历索引逐个查询目标文档 #

拿到具体索引列表后，循环调用get方法查询目标ID的文档：

documents = []
for index in target_indices:
    try:
        doc = await client.get(index=index, id=some_id)
        documents.append(doc)
    except exceptions.NotFoundError:
        # 该索引中无此ID的文档，跳过
        continue
# 最终documents就是所有匹配索引中找到的文档

关于CORS错误的补充 #

如果你的请求是从浏览器前端直接发送到ES服务：

• 需要在Elasticsearch的配置文件（elasticsearch.yml）中添加跨域允许配置：

  http.cors.enabled: true
  http.cors.allow-origin: "你的前端域名，比如http://localhost:3000"
  http.cors.allow-methods: OPTIONS, HEAD, GET, POST, PUT, DELETE
  http.cors.allow-headers: "X-Requested-With, Content-Type, Content-Length, Authorization"
  

• 配置后重启ES服务即可生效。

如果是后端服务调用ES出现CORS错误，大概率是后端处理错误响应时的转发问题，检查后端是否正确捕获ES的错误并返回合法响应，避免前端收到异常跨域信息。

内容的提问来源于stack exchange，提问作者yeaaaahhhh..hamf hamf