連接Elasticsearch(ES)服務器是進行數據搜索和分析的常用操作。Elasticsearch是一個基于Lucene的搜索引擎,提供了RESTful API來進行索引、搜索和管理數據。
連接Elasticsearch(ES)服務器是進行數據搜索和分析的常用操作。Elasticsearch是一個基于Lucene的搜索引擎,提供了RESTful API來進行索引、搜索和管理數據。
以下是一個詳細的Python代碼示例,展示如何連接到Elasticsearch服務器并執(zhí)行一些基本操作。這個示例使用了官方的
elasticsearch-py
客戶端庫。
首先,你需要安裝
elasticsearch
庫。如果你還沒有安裝,可以使用pip進行安裝:
bash
pip install elasticsearch
以下是一個完整的Python腳本,展示了如何連接到Elasticsearch服務器,創(chuàng)建索引,添加文檔,并進行搜索。
from elasticsearch import Elasticsearch, helpers
# 配置Elasticsearch連接
es = Elasticsearch(
['http://localhost:9200'], # Elasticsearch服務器地址和端口
http_auth=('username', 'password'), # 如果需要認證,填寫用戶名和密碼
use_ssl=False, # 如果使用HTTPS,設置為True
verify_certs=False # 如果使用HTTPS且自簽名證書,設置為False
)
# 檢查連接是否成功
if es.ping():
print("Successfully connected to Elasticsearch!")
else:
print("Could not connect to Elasticsearch")
exit()
# 創(chuàng)建索引
index_name = 'my_index'
if not es.indices.exists(index=index_name):
# 定義索引的映射(Schema)
mappings = {
'properties': {
'title': {'type': 'text'},
'content': {'type': 'text'},
'author': {'type': 'keyword'}
}
}
# 創(chuàng)建索引
es.indices.create(index=index_name, body={'mappings': mappings})
print(f"Index '{index_name}' created successfully.")
else:
print(f"Index '{index_name}' already exists.")
# 添加文檔
documents = [
{"_id": 1, "title": "Elasticsearch Basics", "content": "Learn the basics of Elasticsearch.", "author": "John Doe"},
{"_id": 2, "title": "Advanced Elasticsearch", "content": "Go deeper into Elasticsearch features.", "author": "Jane Smith"},
{"_id": 3, "title": "Elasticsearch Performance", "content": "Optimize Elasticsearch for performance.", "author": "Alice Johnson"}
]
# 使用bulk API批量添加文檔
actions = [
{
"_index": index_name,
"_id": doc['_id'],
"_source": doc
}
for doc in documents
]
helpers.bulk(es, actions)
print("Documents added successfully.")
# 搜索文檔
search_body = {
"query": {
"match": {
"content": "Elasticsearch"
}
}
}
response = es.search(index=index_name, body=search_body)
print("Search results:")
for hit in response['hits']['hits']:
print(hit['_source'])
# 清理(可選):刪除索引
# es.indices.delete(index=index_name)
# print(f"Index '{index_name}' deleted successfully.")
Elasticsearch(['http://localhost:9200'])
:連接到運行在本地主機上的Elasticsearch服務器,默認端口為9200。
http_auth=('username', 'password')
:如果Elasticsearch服務器需要認證,填寫用戶名和密碼。
use_ssl
和
verify_certs
:如果連接使用HTTPS,可以啟用這些選項。
es.ping()
方法檢查連接是否成功。
es.indices.exists(index=index_name)
檢查索引是否存在。
es.indices.create(index=index_name, body={'mappings': mappings})
創(chuàng)建索引,并定義文檔的映射。
helpers.bulk(es, actions)
批量添加文檔到索引中。
es.search(index=index_name, body=search_body)
進行搜索,并打印搜索結果。
es.indices.delete(index=index_name)
刪除索引。
use_ssl
和
verify_certs
選項。
如何使用 Pytorch 中的 DataSet 和 DataLoader
閱讀國產操作系統(tǒng)上實現(xiàn)RTMP推流攝像頭視頻和麥克風聲音到流媒體服務器
閱讀多租戶系統(tǒng)數據權限設計與RuoYi系統(tǒng)的借鑒
閱讀count(*)、count(1)哪個更快?面試必問:通宵整理的十道經典MySQL必問面試題
閱讀強化學習筆記之【ACE:Off-PolicyActor-CriticwithCausality-AwareEntropyRegularization】
閱讀使用MailKit在.NET Core中收發(fā)郵件的完整示例
閱讀