一、連接elasticsearch

   // 下載es第三方庫
   pip install elasticsearch
   // 導包
   from elasticsearch import Elasticsearch
   // 連接
   es = Elasticsearch(['127.0.0.1:9200'])
   // 創(chuàng)建索引
   es.indices.create(index='test_index1', ignore=400)
   """
   官方文檔：https://elasticsearch-py.readthedocs.io/
   """

二、基本操作

   // 刪除索引
   es.indices.delete(index='test_index1')
   // 插入數(shù)據(jù)
   es.index(index='test_index1', doc_type='doc', id=1, body={"name": "kitty", "age": 18})
   """
   注意：若不指定id，則id為20為隨機碼
   """

三、基本查詢

   // 按id查詢
   es.get(index='test_index1', doc_type='doc', id=1)
   // 全查(此時不允許出現(xiàn)id！)
   body = {
       "query": {
           "match_all": {}
       }
   }
   es.search(index='test_index1', doc_type='doc', body=body)
   // 按條件查詢
   body = {
       "query": {
           "bool": {
               "must": [
                   "match": {
                       "name": "zqx"
                   }
               ],
               "filter": {
                   "range": {
                       "age": {"gte": 18  }
                   }
               }
           }
       }
   }
   es.search(index='goods', doc_type='fruit', body=body)
   // 按條件刪除
   1)es.delete(index='test_index1', doc_type='doc', id=1)
   2)body = {
         "query": {
              "match": {
                  "name": "zqx"
              }
         }
      }
      es.delete_by_query(index='test_index1', doc_type='doc', body=body)

四、創(chuàng)建mapping

   body = {
       "mappings": {
           "doc": {
               "properties": {
                   "name": {
                       "type": "text",
                  },
                   "age": {
                       "type": "long"
                   }
               }
           }
       }
   }
   es.indices.create(idnex='shang', body=body)