pip install elasticsearch
pip install elasticsearch[async] #支援非同步
from elasticsearch import elasticsearch
from elasticsearch import asyncelasticsearch
es = elasticsearch(host="localhost", port=9200)
#es = asyncelasticsearch()
body = ,
# "_doc":,
"text": ,
"userid": ,
"reprinted": ,
}# }
}}#建立 index
es.indices.create(index = "test", body = body)
#刪除 index
es.indices.delete(index = 'test')
#插入資料
es.index(index = "test", doc_type = "_doc", id = 1, body = )
#可以不用指定id，create會自動新增id。
es.create(index="test", doc_type = "_doc",id = 2, body = )
#刪除指定資料
es.delete(index='test', doc_type='_doc', id=1)
#修改字段
es.update(index = "test", doc_type = "_doc", id = 1, body = })
#查詢資料
es.get(index = "test", doc_type = "_doc", id = 1)
es.search(index = "test", doc_type = "_doc", body = query)
#滾動分頁的func，第四塊部分 分頁查詢中 說明
es.scroll(scroll_id = "scroll_id", scroll = "5m")
#批量插入&批量更新
""",
} 插入的每乙個資料中，都需要指定 _index,_type,_id 更新、插入的資料放在doc中
"""from elasticsearch.helpers import async_bulk,bulk
async def main():
await async_bulk(es, data)
bulk(es, data)
es.search(index = "test", doc_type = "_doc", body = body, size = 10)
"""index、doc_type、body
size = 10 : 返回的資料量
filter_path = [ 'hits.hits._id','hits.hits._type']: 用於指定響應的內容
default_operator: 指定查詢的運算子 and或者or 預設值為：or
from_ = 0 ： 返回資料的起始值，用於分頁
scroll = "5m" : 是否記錄滾動翻頁的索引值， 記錄5分鐘
"""#返回所有資料
body = }}
#指定檢索字段
body = }}
#範圍查詢
"""gt:大於
gte：大於等於
lt：小於
lte：小於等於
"""}}}
#排序body = ,
"sort":[}]
}#分頁,從第10個資料開始，返回10條資料。 == [10:20]
es.search(size = 10, from_ = 10)
#使用滾動分頁，速度快，查詢後會記錄最後一條資料，不適用跳頁查詢。
es.search(scroll = "5m")
es.scroll(scroll_id = "_scroll_id", scroll = "5m")
python elasticsearch 分組統計
聚合 aggregations query must not should size 0,設定返回資訊條數 aggs aggs 設定fielddata true 在系統終端設定 將以上標紅位置更改為自己對應的字段，在linux上似乎可以直接操作，windows似乎需要下乙個curl外掛程式，我未曾設...
Spring Integration基本用法
關於spring integration的介紹這裡不需要贅述，現在我們需要實現的是傳送乙個param,裡面有兩個引數datatype和data,datatype是0和1除外的捨棄，剩餘datatype 0的資料往oldchannel通道發，剩餘datatype 1的資料往newchannel通道發，...
elastic search head 基本用法
elastic search head 基本用法 es 安裝方法 資源監控和集群管理外掛程式 bin plugin install lukas vlcek bigdesk 資料查詢外掛程式 bin plugin install mobz elasticsearch head 理解性 index 類似...