python-elasticsearch從建立索引到寫入數據

建立索引
from elasticsearch import Elasticsearch
es = Elasticsearch('192.168.1.1:9200')

mappings = {
            "mappings": {
                "type_doc_test": {                           #type_doc_test爲doc_type
                    "properties": {
                        "id": {
                            "type": "long",
                            "index": "false"
                        },
                        "serial": {
                            "type": "keyword",  # keyword不會進行分詞,text會分詞
                            "index": "false"  # 不建索引
                        },
                        #tags能夠存json格式，訪問tags.content
                        "tags": {
                            "type": "object",
                            "properties": {
                                "content": {"type": "keyword", "index": True},
                                "dominant_color_name": {"type": "keyword", "index": True},
                                "skill": {"type": "keyword", "index": True},
                            }
                        },
                        "hasTag": {
                            "type": "long",
                            "index": True
                        },
                        "status": {
                            "type": "long",
                            "index": True
                        },
                        "createTime": {
                            "type": "date",
                            "format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
                        },
                        "updateTime": {
                            "type": "date",
                            "format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
                        }
                    }
                }
            }
        }

res = es.indices.create(index = 'index_test',body =mappings)
經過以上代碼便可建立es索引

寫入一條數據
寫入數據須要根據 建立的es索引類型對應的數據結構寫入：

from elasticsearch import Elasticsearch

es = Elasticsearch('192.168.1.1:9200')

action ={
              "id": "1111122222",
              "serial":"版本",
              #如下tags.content是錯誤的寫法
              #"tags.content" :"標籤2",
              #"tags.dominant_color_name": "域名的顏色黃色",
              #正確的寫法以下：
              "tags":{"content":"標籤3","dominant_color_name": "域名的顏色黃色"},
              #按照字典的格式寫入，若是用上面的那種寫法，會直接寫成一個tags.content字段。
              #而不是在tags中content添加數據，這點須要注意
              "tags.skill":"分類信息",
              "hasTag":"123",
              "status":"11",
              "createTime" :"2018-2-2",
              "updateTime":"2018-2-3",
                }
es.index(index="index_test",doc_type="doc_type_test",body = action)
便可寫入一條數據
錯誤的寫入

正確的寫入

寫入多條數據
from elasticsearch import Elasticsearch
from elasticsearch.helpers import bulk

es = Elasticsearch('192.168.1.1:9200')

ACTIONS = []

action1 ={
                    "_index": "indes_test",
                    "_type": "doc_type_test",
                    "_id":"bSlegGUBmJ2C8ZCSC1R1",
                    "_source":{
                        "id": "1111122222",
                        "serial":"版本",
                        "tags.content" :"標籤2",
                        "tags.dominant_color_name": "域名的顏色黃色",
                        "tags.skill":"分類信息",
                        "hasTag":"123",
                        "status":"11",
                        "createTime" :"2018-2-2",
                        "updateTime":"2018-2-3",
                    }
                }
action2 ={
                    "_index": "indes_test",
                    "_type": "doc_type_test",
                    "_id":"bSlegGUBmJ2C8ZCSC1R2",
                    "_source":{
                        "id": "1111122222",
                        "serial":"版本",
                        "tags.content" :"標籤2",
                        "tags.dominant_color_name": "域名的顏色黃色",
                        "tags.skill":"分類信息",
                        "hasTag":"123",
                        "status":"11",
                        "createTime" :"2018-2-2",
                        "updateTime":"2018-2-3",
                    }
                }

ACTIONS.append(action1)
ACTIONS.append(action2)

res,_ =bulk(es, ACTIONS, index="indes_test", raise_on_error=True)
print(res)
這個方式是手動指定了id，若是把」_id」這個參數去掉便可自動生成id數據. 
以下：

action2 ={
                    "_index": "indes_test",
                    "_type": "doc_type_test",

                    "_source":{
                        "id": "1111122222",
                        "serial":"版本",
                        "tags.content" :"標籤2",
                        "tags.dominant_color_name": "域名的顏色黃色",
                        "tags.skill":"分類信息",
                        "hasTag":"123",
                        "status":"11",
                        "createTime" :"2018-2-2",
                        "updateTime":"2018-2-3",
                    }
                }
刪除一條數據
from elasticsearch import Elasticsearch

es = Elasticsearch('192.168.1.1:9200')

res = es.delete(index="index_test",doc_type="doc_type_test", id ="bSlegGUBmJ2C8ZCSC1R1")
print(res)
直接替換id的便可刪除所需的id
查詢一條數據
from elasticsearch import Elasticsearch

es = Elasticsearch('192.168.1.1:9200')

res = es.get(index="index_test",doc_type="doc_type_test",  id ="bSlegGUBmJ2C8ZCSC1R2")
print(res)
直接替換id的便可查詢所需的id
查詢全部數據
from elasticsearch import Elasticsearch

es = Elasticsearch('192.168.1.1:9200')

res = es.search(index="index_test",doc_type="doc_type_test")
print(res)
print(res['hits']['hits'])

經過['hits']參數，能夠解析出查詢數據的詳細內容
根據關鍵詞查找

from elasticsearch import Elasticsearch

es = Elasticsearch('192.168.1.1:9200')

doc = {
            "query": {
                "match": {
                    "_id": "aSlZgGUBmJ2C8ZCSPVRO"
                }
            }
        }

res = es.search(index="index_test",doc_type="doc_type_test",body=doc) print（res）