使用Elasticsearch的Delete By Query API可以根據條件刪除數據。以下是一個示例:
from elasticsearch import Elasticsearch
# 連接到Elasticsearch實例
es = Elasticsearch(['localhost:9200'])
# 刪除匹配條件的文檔
delete_query = {
"query": {
"match": {
"field1": "value1"
}
}
}
response = es.delete_by_query(index='your_index', body=delete_query)
print(response)
上述示例中,我們使用match
查詢來指定刪除條件,field1
是要匹配的字段名,"value1"是要匹配的值。你可以根據自己的需求修改查詢條件。
注意,刪除操作是不可逆的,請謹慎使用。