Elasticsearch Python嗅探报错：初始嗅探未发现可用节点

核心原因与修复方案 #

1. 端口映射不匹配 #

elasticsearch-py默认会直接使用节点/_nodes/_all/http返回的publish_address中的端口，但如果你的ES集群内网监听9200，公网通过安全组转发到443（HTTPS默认端口），客户端嗅探到9200端口后会尝试直接连接，导致无法访问。

修复方式：

• 在elasticsearch.yml中显式设置公网访问端口：

  http.publish_port: 443
  

• 或在客户端初始化时手动映射端口：

  from elasticsearch import Elasticsearch
  
  es = Elasticsearch(
      ["https://x.x.x.x:443"],
      sniff_on_start=True,
      sniffer_timeout=60,
      port_forwards={9200: 443}  # 将内网端口映射为公网端口
  )
  

2. 协议自动识别异常 #

如果ES集群内网用HTTP、公网用HTTPS，节点返回的publish_address可能不带协议头，elasticsearch-py会默认用HTTP连接公网地址，被HTTPS服务拒绝。

修复方式：
初始化客户端时强制指定HTTPS协议，同时处理自签名证书的情况（如果适用）：

es = Elasticsearch(
    ["x.x.x.x:443"],
    sniff_on_start=True,
    scheme="https",
    ssl_show_warn=False,  # 自签名证书时禁用警告
    verify_certs=False     # 自签名证书时跳过验证
)

3. 自定义嗅探逻辑 #

如果默认嗅探逻辑无法正确解析节点地址，可自定义回调函数手动处理：

from elasticsearch import Elasticsearch

def custom_sniff(hosts, session, **kwargs):
    nodes = session.perform_request("GET", "/_nodes/_all/http")
    new_hosts = []
    for node in nodes["nodes"].values():
        # 提取公网IP和端口，强制拼接HTTPS地址
        ip, port = node["http"]["publish_address"].split(":")
        new_hosts.append(f"https://{ip}:{port}")
    return new_hosts

es = Elasticsearch(
    ["https://x.x.x.x:443"],
    sniff_on_start=True,
    sniff_callback=custom_sniff
)

4. 版本兼容性问题 #

elasticsearch-py与ES集群版本不匹配时，可能存在嗅探逻辑的兼容性问题。确保客户端版本与ES集群主版本一致：

pip install elasticsearch==<你的ES集群版本号>

例如ES集群为7.17.x，就安装elasticsearch==7.17.10。

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