Python連接es筆記之創(chuàng)建和刪除操作示例詳解
索引和數(shù)據(jù)的創(chuàng)建和刪除
其實(shí)對于索引來說,如果可以接觸到 kibana 的話,可以很方便的在界面進(jìn)行操作,這里簡單介紹一下如何使用代碼來操作索引的創(chuàng)建和刪除。
索引的創(chuàng)建和刪除操作
使用的還是 es 的連接:
from elasticsearch_dsl import connections connections.configure( default={"hosts": "localhost:9200"}, ) conn = connections.connections.get_connection("default")
創(chuàng)建索引
index_name = "test_create" conn.indices.create(index_name)
檢測索引是否存在
print(conn.indices.exists(index_name))
返回的是一個(gè)布爾型數(shù)據(jù)。
刪除索引
conn.indices.delete(index_name)
數(shù)據(jù)的創(chuàng)建和刪除
創(chuàng)建單條數(shù)據(jù)
還是默認(rèn)使用剛剛創(chuàng)建的索引 test_create
,我們需要往里面加入一條數(shù)據(jù),示例如下:
index_name = "test_create" conn.index( index=index_name, id=1, body={ "name": "李白" } )
這樣就往里面寫入了一條 id=1 的數(shù)據(jù),如果不指定 id 參數(shù),系統(tǒng)會為我們自動(dòng)分配一個(gè) id:
conn.index( index=index_name, body={ "name": "李白" } )
這種創(chuàng)建方式也是允許的。
批量創(chuàng)建數(shù)據(jù)
這里用到在批量更新時(shí)候的使用過的 elasticsearch.helpers 函數(shù)。
示例如下:
action_1 = { "_op_type": "index", "_index": "test_create", "doc": {"age": 20, "name": "楊過", "address": "終南山"}, } action_2 = { "_op_type": "index", "_index": "test_create", "doc": {"age": 21, "name": "郭靖", "address": "桃花島"}, } action_list = [action_1, action_2] helpers.bulk(conn, actions=action_list)
在這里,因?yàn)槭莿?chuàng)建數(shù)據(jù),所以 _op_type 的值為 index,剩下的使用方法和之前更新的操作一致。
刪除操作
刪除操作在第一篇筆記介紹查詢數(shù)據(jù)的時(shí)候帶過一筆,就是通過 Search() 方法加入條件后,不執(zhí)行 execute(),而是執(zhí)行 delete() 函數(shù)進(jìn)行刪除:
s = Search(using="default").index("exam").query("match", name="張三豐") s.delete()
還有一種 es 連接直接操作的 delete_by_query() 函數(shù),示例如下:
conn = connections.connections.get_connection("default") q1 = ES_Q("term", name="楊過") conn.delete_by_query( index="exam", body={ "query": q1 } )
以上就是Python連接es筆記之創(chuàng)建和刪除操作示例詳解的詳細(xì)內(nèi)容,更多關(guān)于Python連接es創(chuàng)建刪除操作的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Python selenium+cookie實(shí)現(xiàn)免密登陸的示例代碼
本文主要介紹了Python selenium+cookie實(shí)現(xiàn)免密登陸的示例代碼,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-02-02使用Dajngo 通過代碼添加xadmin用戶和權(quán)限(組)
這篇文章主要介紹了使用Dajngo 通過代碼添加xadmin用戶和權(quán)限(組),具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-07-07python學(xué)習(xí)字符串駐留與常量折疊隱藏特性詳解
這篇文章主要為大家介紹了python學(xué)習(xí)中字符串駐留與常量折疊的一些隱藏特性,并給大家進(jìn)行了詳細(xì)分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助2021-09-09python3利用Socket實(shí)現(xiàn)通信的方法示例
這篇文章主要介紹了python3利用Socket實(shí)現(xiàn)通信的方法示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-05-05python機(jī)器學(xué)習(xí)GCN圖卷積神經(jīng)網(wǎng)絡(luò)原理解析
這篇文章主要為大家介紹了GCN圖卷積神經(jīng)網(wǎng)絡(luò)原理及代碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-05-05Python報(bào)錯(cuò):PermissionError:?[Errno?13]?Permission?denied的解
這篇文章主要給大家介紹了關(guān)于Python報(bào)錯(cuò):PermissionError:?[Errno?13]?Permission?denied的解決辦法,文中給出了詳細(xì)的解決辦法,需要的朋友可以參考下2022-02-02