es异步增添数据示例

以下是一个简单的示例代码，演示如何使用 Elasticsearch 的异步 API 增加一条数据：

from elasticsearch import AsyncElasticsearch

async def add_data():
    # 创建 Elasticsearch 客户端对象
    es = AsyncElasticsearch(["localhost"])

    # 定义要增加的数据
    data = {
        "title": "示例文档",
        "content": "这是一篇示例文档，用于演示 Elasticsearch 的异步 API。",
        "tags": ["elasticsearch", "python", "异步编程"]
    }

    # 调用异步 API 增加数据
    response = await es.index(index="my_index", body=data)

    # 输出响应结果
    print(response)

# 调用异步函数
await add_data()

在上面的示例中，我们首先创建了一个 `AsyncElasticsearch` 对象，然后定义了要增加的数据。接着，我们调用了 `es.index()` 方法来异步地增加数据，并将响应结果输出到控制台。最后，我们通过 `await` 关键字来等待异步函数的执行结果。

需要注意的是，为了使用 Elasticsearch 的异步 API，我们需要安装 `elasticsearch-async` 库，而不是普通的 `elasticsearch` 库。