通过以下步骤安装必要的Python库:
$ pip install elasticsearch
连接到Elasticsearch,创建一个文档(例如,数据条目),然后使用Elasticsearch对文档进行“索引”。
from datetime import datetime from elasticsearch import Elasticsearch # Connect to Elasticsearch using default options (localhost:9200) es = Elasticsearch() # Define a simple Dictionary object that we'll index to make a document in ES doc = { 'author': 'kimchy', 'text': 'Elasticsearch: cool. bonsai cool.', 'timestamp': datetime.now(), } # Write a document res = es.index(index="test-index", doc_type='tweet', id=1, body=doc) print(res['created']) # Fetch the document res = es.get(index="test-index", doc_type='tweet', id=1) print(res['_source']) # Refresh the specified index (or indices) to guarantee that the document # is searchable (avoid race conditions with near realtime search) es.indices.refresh(index="test-index") # Search for the document res = es.search(index="test-index", body={"query": {"match_all": {}}}) print("Got %d Hits:" % res['hits']['total']) # Show each "hit" or search response (max of 10 by default) for hit in res['hits']['hits']: print("%(timestamp)s %(author)s: %(text)s" % hit["_source"])