Python如何操作Elasticsearch？elasticsearch-py

elasticsearch-py

elasticsearch-py

pip install elasticsearch

from elasticsearch import Elasticsearch

# 默认连接到 localhost:9200
es = Elasticsearch("http://localhost:9200") 

# 检查连接是否成功，ping()方法会发送一个HEAD请求
if es.ping():
    print("成功连接到Elasticsearch！")
else:
    print("无法连接到Elasticsearch，请检查服务是否运行或地址是否正确。")

# 索引一个文档
doc = {
    'author': '张三',
    'text': 'Python操作Elasticsearch真是太方便了。',
    'timestamp': '2023-10-27T10:00:00'
}
resp = es.index(index="my_index", id=1, document=doc)
print(f"索引文档结果: {resp['result']}")

# 获取一个文档
get_resp = es.get(index="my_index", id=1)
print(f"获取文档内容: {get_resp['_source']}")

# 搜索文档
# 最简单的match_all查询，获取所有文档
search_body = {
    "query": {
        "match_all": {}
    }
}
search_resp = es.search(index="my_index", body=search_body)
print(f"搜索到 {search_resp['hits']['total']['value']} 个文档。")
for hit in search_resp['hits']['hits']:
    print(f"文档ID: {hit['_id']}, 内容: {hit['_source']}")

# 更新一个文档
update_body = {
    "doc": {
        "text": "Python操作Elasticsearch确实很方便，而且功能强大。"
    }
}
update_resp = es.update(index="my_index", id=1, body=update_body)
print(f"更新文档结果: {update_resp['result']}")

# 删除一个文档
delete_resp = es.delete(index="my_index", id=1)
print(f"删除文档结果: {delete_resp['result']}")

elasticsearch-py

localhost:9200

from elasticsearch import Elasticsearch
import ssl

# 假设你的Elasticsearch集群节点地址
# 如果是云服务，比如Elastic Cloud，地址会更复杂，通常是带端口的域名
es_hosts = [
    {'host': 'your_es_host1.com', 'port': 9200},
    {'host': 'your_es_host2.com', 'port': 9200},
]

# 如果启用了HTTPS，并且需要验证证书
# ca_certs: 你的CA证书路径，用于验证Elasticsearch服务器的身份
# verify_certs: 是否验证服务器证书
# ssl_show_warn: 如果为True，当证书验证失败时会打印警告
context = ssl.create_default_context(cafile="/path/to/your/ca.crt")
# 如果不需要验证服务器证书（不推荐在生产环境使用）
# context = ssl._create_unverified_context() 

# 处理基本认证 (用户名和密码)
# 也可以通过http_auth=('username', 'password')参数直接传入
username = 'elastic'
password = 'your_password'

try:
    es = Elasticsearch(
        es_hosts,
        # scheme="https", # 如果默认是http，需要明确指定https
        # use_ssl=True, # 早期版本可能需要，现在通常根据scheme自动判断
        # verify_certs=True, # 是否验证证书
        # ssl_context=context, # 传入SSL上下文
        http_auth=(username, password),
        timeout=30 # 设置连接超时，防止长时间等待
    )

    if es.ping():
        print("成功连接到受认证的Elasticsearch集群！")
    else:
        print("无法连接到Elasticsearch集群，请检查配置或认证信息。")

except Exception as e:
    print(f"连接Elasticsearch集群时发生错误: {e}")

# 连接时，如果遇到连接超时或者认证失败，这些错误都会在这里被捕获。
# 实际操作中，这些参数需要根据你的Elasticsearch部署情况来配置。
# 特别是证书路径和认证信息，务必保密。

ssl_context

cafile