elasticsearch_dsl demo
时间: 2023-09-04 20:12:38 浏览: 230
以下是一个使用elasticsearch_dsl的示例代码:
```python
# 引入必要的包
from elasticsearch_dsl import connections, Search
from elasticsearch import Elasticsearch
# 连接到elasticsearch
es = connections.create_connection(hosts=["127.0.0.1:9200"], timeout=20)
# 查询操作
search = Search(using=es, index="account_info")
response = search.query("match", firstname="John").execute()
for hit in response:
print(hit.firstname, hit.lastname)
# 更新文档
doc = search.get(id="1")
doc.balance += 100
doc.save()
# 删除文档
search.delete(id="2")
# 关闭连接
es.close()
```
以上示例代码展示了elasticsearch_dsl的基本用法。首先我们连接到elasticsearch实例,然后可以执行查询、更新和删除操作。在查询操作中,我们使用`Search`对象来构建查询条件,并执行`execute()`方法获取查询结果。在更新操作中,我们通过获取文档对象并修改其属性值,然后调用`save()`方法保存修改。在删除操作中,我们使用`delete()`方法指定要删除的文档id。最后,我们关闭连接。
请注意,以上示例中的索引名为"account_info",如果你使用的是不同的索引,请将其替换为你的索引名。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [python中elasticsearch_dsl模块用法详解](https://blog.csdn.net/m0_72557783/article/details/126957624)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]
阅读全文
相关推荐
















