### ### 在 Python 中使用 Elasticsearch 并通过 `.p12` 证书进行认证 在使用 Elasticsearch 时，为了确保通信的安全性，通常会启用 TLS 加密，并通过 `.p12` 格式的证书进行客户端认证。Python 提供了 `elasticsearch` 客户端库，支持通过配置 SSL 证书连接安全的 Elasticsearch 集群。 由于 `elasticsearch` 客户端默认支持 `.pem` 格式的证书文件，因此在使用 `.p12` 文件时，需要先将其转换为 `.pem` 格式。以下是完整的实现方法： #### ### 1. 转换 `.p12` 证书为 `.pem` 格式 使用 `openssl` 工具将 `.p12` 文件转换为 `.pem` 格式，以便在 Python 客户端中使用： ```bash openssl pkcs12 -in elastic-certificates.p12 -out elastic-certificates.pem -nodes ``` 该命令会将 `.p12` 文件中的私钥和证书提取到 `.pem` 文件中，便于 Python 客户端加载[^1]。 #### ### 2. 使用 Python 连接 Elasticsearch 并启用 `.pem` 证书认证 在完成证书转换后，可以使用 `elasticsearch` 库连接启用 TLS 的 Elasticsearch 实例： ```python from elasticsearch import Elasticsearch # 配置 Elasticsearch 客户端 es = Elasticsearch( hosts=["https://localhost:9200"], http_auth=("username", "password"), ca_certs="/path/to/elastic-certificates.pem", client_cert="/path/to/client-cert.pem", client_key="/path/to/client-key.pem" ) # 测试连接 print(es.ping()) ``` 其中： - `ca_certs` 指定用于验证服务器证书的 CA 证书。 - `client_cert` 和 `client_key` 分别指定客户端证书和私钥，用于身份验证。 如果使用的是 `.p12` 文件，也可以通过 `requests` 库直接指定 `.p12` 文件路径进行连接： ```python import requests from elasticsearch import Elasticsearch # 自定义请求会话，支持 .p12 证书 session = requests.Session() session.cert = ('/path/to/cert.pem', '/path/to/key.pem') # 使用自定义会话连接 Elasticsearch es = Elasticsearch( hosts=["https://localhost:9200"], http_auth=("username", "password"), ca_certs="/path/to/ca.pem", connection_class=type('CustomConnection', (object,), {'session': session}) ) print(es.ping()) ``` #### ### 3. 使用 `.p12` 证书进行安全通信的注意事项 - 确保 `.p12` 文件的密码正确，否则转换或连接会失败。 - 如果 Elasticsearch 使用的是自签名证书，需在连接时设置 `verify_certs=False`，但不推荐用于生产环境。 - 在集群部署时，一个集群只需生成一次 `.p12` 证书，其他节点可共享该证书文件。 ###