锟斤拷锟斤拷位锟矫ｏ拷锟斤拷页 > 锟斤拷锟斤拷锟教筹拷 > 锟教筹拷 > 锟斤拷锟斤拷Elasticsearch锟斤拷锟斤拷锟斤拷锟斤拷Python锟斤拷锟斤拷示锟斤拷

锟斤拷锟斤拷Elasticsearch锟斤拷锟斤拷锟斤拷锟斤拷Python锟斤拷锟斤拷示锟斤拷

锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷|锟斤拷时锟戒：2024-10-25 09:46:34 |锟斤拷锟侥讹拷锟斤拷162锟斤拷|锟斤拷锟斤拷签锟斤拷 a T last El S C AR 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 EA cs Python 锟斤拷 |锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷戏

锟斤拷锟斤拷Elasticsearch锟斤拷ES锟斤拷锟斤拷锟斤拷锟斤拷锟角斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵凤拷锟斤拷锟侥筹拷锟矫诧拷锟斤拷锟斤拷Elasticsearch锟斤拷一锟斤拷锟斤拷锟斤拷Lucene锟斤拷锟斤拷锟斤拷锟斤拷锟芥，锟结供锟斤拷RESTful API锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵癸拷锟斤拷锟斤拷锟捷★拷

锟斤拷锟斤拷锟斤拷一锟斤拷锟斤拷细锟斤拷Python锟斤拷锟斤拷示锟斤拷锟斤拷展示锟斤拷锟斤拷锟斤拷拥锟紼lasticsearch锟斤拷锟斤拷锟斤拷锟斤拷执锟斤拷一些锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞撅拷锟绞癸拷锟斤拷斯俜锟斤拷锟� elasticsearch-py 锟酵伙拷锟剿库。

1. 锟斤拷装Elasticsearch锟酵伙拷锟剿匡拷

锟斤拷锟饺ｏ拷锟斤拷锟斤拷要锟斤拷装 elasticsearch 锟解。锟斤拷锟斤拷慊姑伙拷邪锟阶帮拷锟斤拷锟斤拷锟绞癸拷锟絧ip锟斤拷锟叫帮拷装锟斤拷

bash
pip install elasticsearch

2. 锟斤拷锟接碉拷Elasticsearch锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷Python锟脚憋拷锟斤拷展示锟斤拷锟斤拷锟斤拷锟斤拷拥锟紼lasticsearch锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

from elasticsearch import Elasticsearch, helpers  
  
# 锟斤拷锟斤拷Elasticsearch锟斤拷锟斤拷  
es = Elasticsearch(  
    ['http://localhost:9200'],  # Elasticsearch锟斤拷锟斤拷锟斤拷锟斤拷址锟酵端匡拷  
    http_auth=('username', 'password'),  # 锟斤拷锟斤拷锟揭拷锟街わ拷锟斤拷锟叫达拷没锟斤拷锟斤拷锟斤拷锟斤拷锟�  
    use_ssl=False,  # 锟斤拷锟绞癸拷锟紿TTPS锟斤拷锟斤拷锟斤拷为True  
    verify_certs=False  # 锟斤拷锟绞癸拷锟紿TTPS锟斤拷锟斤拷签锟斤拷证锟介，锟斤拷锟斤拷为False  
)  
  
# 锟斤拷锟斤拷锟斤拷锟斤拷欠锟缴癸拷  
if es.ping():  
    print("Successfully connected to Elasticsearch!")  
else:  
    print("Could not connect to Elasticsearch")  
    exit()  
  
# 锟斤拷锟斤拷锟斤拷锟斤拷  
index_name = 'my_index'  
if not es.indices.exists(index=index_name):  
    # 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷映锟戒（Schema锟斤拷  
    mappings = {  
        'properties': {  
            'title': {'type': 'text'},  
            'content': {'type': 'text'},  
            'author': {'type': 'keyword'}  
        }  
    }  
    # 锟斤拷锟斤拷锟斤拷锟斤拷  
    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.")

3. 锟斤拷锟斤拷锟斤拷锟�

锟斤拷锟斤拷锟斤拷锟矫ｏ拷
- Elasticsearch(['http://localhost:9200']) 锟斤拷锟斤拷锟接碉拷锟斤拷锟斤拷锟节憋拷锟斤拷锟斤拷锟斤拷锟较碉拷Elasticsearch锟斤拷锟斤拷锟斤拷锟斤拷默锟较端匡拷为9200锟斤拷
- http_auth=('username', 'password') 锟斤拷锟斤拷锟紼lasticsearch锟斤拷锟斤拷锟斤拷锟斤拷要锟斤拷证锟斤拷锟斤拷写锟矫伙拷锟斤拷锟斤拷锟斤拷锟诫。
- use_ssl 锟斤拷 verify_certs 锟斤拷锟斤拷锟斤拷锟斤拷锟绞癸拷锟紿TTPS锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷些选锟筋。
锟斤拷锟斤拷锟斤拷樱锟�
- 使锟斤拷 es.ping() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷欠锟缴癸拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
- 使锟斤拷 es.indices.exists(index=index_name) 锟斤拷锟斤拷锟斤拷锟斤拷欠锟斤拷锟节★拷
- 使锟斤拷 es.indices.create(index=index_name, body={'mappings': mappings}) 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥碉拷锟斤拷映锟戒。
锟斤拷锟斤拷锟侥碉拷锟斤拷
- 使锟斤拷 helpers.bulk(es, actions) 锟斤拷锟斤拷锟斤拷锟斤拷锟侥碉拷锟斤拷锟斤拷锟斤拷锟叫★拷
锟斤拷锟斤拷锟侥碉拷锟斤拷
- 使锟斤拷 es.search(index=index_name, body=search_body) 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷印锟斤拷锟斤拷锟斤拷锟斤拷锟�
锟斤拷锟斤拷锟斤拷锟斤拷选锟斤拷锟斤拷
- 使锟斤拷 es.indices.delete(index=index_name) 删锟斤拷锟斤拷锟斤拷锟斤拷

4. 注锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷锟斤拷址 锟斤拷确锟斤拷Elasticsearch锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫ｏ拷锟斤拷锟揭碉拷址锟酵端匡拷锟斤拷锟斤拷锟斤拷确锟斤拷
锟斤拷证 锟斤拷锟斤拷锟紼lasticsearch锟斤拷锟斤拷锟斤拷锟斤拷要锟斤拷证锟斤拷确锟斤拷锟结供锟斤拷确锟斤拷锟矫伙拷锟斤拷锟斤拷锟斤拷锟诫。
SSL 锟斤拷锟斤拷锟斤拷锟斤拷锟绞癸拷锟紿TTPS锟斤拷锟斤拷锟斤拷确锟斤拷锟斤拷 use_ssl 锟斤拷 verify_certs 选锟筋。

小锟斤拷锟狡硷拷锟侥讹拷

锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥斤拷为锟斤拷锟斤拷锟斤拷息锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷同锟斤拷锟睫观碉拷锟街な碉拷锟斤拷锟斤拷锟斤拷锟�

a 1.0: 锟斤拷锟酵ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷营状态锟斤拷锟斤拷式锟斤拷营锟斤拷锟斤拷锟斤拷锟皆ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷; 锟斤拷戏锟斤拷锟斤拷

锟斤拷戏锟斤拷锟�

锟斤拷戏锟斤拷频

锟斤拷戏锟斤拷锟斤拷

锟斤拷戏锟筋动; 锟斤拷alittletotheleft锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一锟筋备锟杰伙拷迎锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷戏锟斤拷锟斤拷业锟斤拷锟斤拷锟斤拷嵌锟斤拷粘锟斤拷锟斤拷锟斤拷械母锟斤拷锟斤拷锟斤拷锟斤拷锟�