是的,AsyncElasticsearch客户端在异步操作中使用同样的会话。
以下是一个使用AsyncElasticsearch客户端的示例,展示了它在异步操作中使用同一个会话:
from elasticsearch import AsyncElasticsearch
async def query_es():
es = AsyncElasticsearch()
# 获取文档
doc = await es.get(index="my_index", id="my_id")
# 更新文档
await es.update(index="my_index", id="my_id", body={"doc": {"my_field": "new_value"}})
await query_es()
在上面的示例中,我们使用AsyncElasticsearch客户端获取和更新了同一文档。由于异步操作是非阻塞的,因此每个操作都可以在同一个会话中进行,而不会阻塞其他操作。