Python連接es筆記之創(chuàng)建和刪除操作示例詳解
索引和數(shù)據(jù)的創(chuàng)建和刪除
其實對于索引來說,如果可以接觸到 kibana 的話,可以很方便的在界面進行操作,這里簡單介紹一下如何使用代碼來操作索引的創(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))
返回的是一個布爾型數(shù)據(jù)。
刪除索引
conn.indices.delete(index_name)
數(shù)據(jù)的創(chuàng)建和刪除
創(chuàng)建單條數(shù)據(jù)
還是默認使用剛剛創(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)會為我們自動分配一個 id:
conn.index(
index=index_name,
body={
"name": "李白"
}
)這種創(chuàng)建方式也是允許的。
批量創(chuàng)建數(shù)據(jù)
這里用到在批量更新時候的使用過的 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)在這里,因為是創(chuàng)建數(shù)據(jù),所以 _op_type 的值為 index,剩下的使用方法和之前更新的操作一致。
刪除操作
刪除操作在第一篇筆記介紹查詢數(shù)據(jù)的時候帶過一筆,就是通過 Search() 方法加入條件后,不執(zhí)行 execute(),而是執(zhí)行 delete() 函數(shù)進行刪除:
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)建和刪除操作示例詳解的詳細內(nèi)容,更多關(guān)于Python連接es創(chuàng)建刪除操作的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Python selenium+cookie實現(xiàn)免密登陸的示例代碼
本文主要介紹了Python selenium+cookie實現(xiàn)免密登陸的示例代碼,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2022-02-02
使用Dajngo 通過代碼添加xadmin用戶和權(quán)限(組)
這篇文章主要介紹了使用Dajngo 通過代碼添加xadmin用戶和權(quán)限(組),具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-07-07
python3利用Socket實現(xiàn)通信的方法示例
這篇文章主要介紹了python3利用Socket實現(xiàn)通信的方法示例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2019-05-05
python機器學習GCN圖卷積神經(jīng)網(wǎng)絡原理解析
這篇文章主要為大家介紹了GCN圖卷積神經(jīng)網(wǎng)絡原理及代碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-05-05
Python報錯:PermissionError:?[Errno?13]?Permission?denied的解
這篇文章主要給大家介紹了關(guān)于Python報錯:PermissionError:?[Errno?13]?Permission?denied的解決辦法,文中給出了詳細的解決辦法,需要的朋友可以參考下2022-02-02

