Python调用Elasticsearch search接口遇ConnectionError(Errno61)求助

矛盾点分析 #

es.info执行正常但es.search抛出连接拒绝错误，说明初始连接校验通过，但实际搜索请求的连接路径或配置存在问题，而非基础连通性故障。

排查步骤 #

• 明确请求协议：错误栈显示使用HTTPSConnection，但初始化客户端时未指定协议，导致协议不匹配。修改初始化代码，明确指定HTTP/HTTPS：

  # HTTPS场景（若集群启用HTTPS）
  es = Elasticsearch(['https://<hostname>:9200'], basic_auth=(user, passw), verify_certs=False)
  # HTTP场景
  es = Elasticsearch(['http://<hostname>:9200'], basic_auth=(user, passw))
  

  注：verify_certs=False仅用于测试，生产环境需配置合法证书。

• 验证索引合法性：<index-name>可能拼写错误、大小写不匹配或不存在。先执行以下代码确认索引状态：

  print(es.indices.exists(index="<index-name>"))
  

  返回False则需修正索引名称。

• 检查集群路由配置：部分集群会分离协调节点与数据节点，info接口允许协调节点访问，但search请求需指向数据节点/负载均衡地址。确认集群提供的正确访问端点。

• 终端直接测试连通性：用curl绕过代码验证接口可用性：

  # HTTPS示例
  curl -u <user>:<passw> https://<hostname>:9200/<index-name>/_search -d '{"aggs": {"keys": {"terms": {"field": "kubernetes.container_name", "size": 600}}}, "size": 0}' -H "Content-Type: application/json"
  # HTTP示例
  curl -u <user>:<passw> http://<hostname>:9200/<index-name>/_search -d '{"aggs": {"keys": {"terms": {"field": "kubernetes.container_name", "size": 600}}}, "size": 0}' -H "Content-Type: application/json"
  

  若curl也报错，说明是网络/集群配置问题，需检查防火墙、节点状态。

• 版本兼容性检查：客户端与ES集群版本差距过大可能引发兼容性问题。执行pip show elasticsearch查看客户端版本，通过es.info()获取集群版本，确保两者版本差不超过1个大版本。

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