object ObjectApiResponse can't be used in 'await' expression

[772201902]

elasticsearch-dsl~=8.17.1

I want to use ES's asynchronous query. I have verified that it is available during synchronization, but there will be an error when using the corresponding asynchronous library

The code is as follows:
EsClient = elasticsearch.Elasticsearch(config.esArgs.uri, basic_auth=(config.esArgs.user, config.esArgs.passwd))
query_obj = elasticsearch_dsl.AsyncSearch(using=EsClient, index=index)
query_obj = query_obj.query(body)
response =await query_obj.execute()
logging.debug(f"response: {response}")

[miguelgrinberg]

This works well for me:

import asyncio
import logging
import os
import elasticsearch
import elasticsearch_dsl

logging.basicConfig(level=logging.INFO)

async def main():
    EsClient = elasticsearch.AsyncElasticsearch(os.environ['ELASTICSEARCH_URL'])
    query_obj = elasticsearch_dsl.AsyncSearch(using=EsClient, index='my-index')
    query_obj = query_obj.query(elasticsearch_dsl.query.MatchAll())
    response = await query_obj.execute()
    logging.info(f"response: {response}")
    await EsClient.close()

asyncio.run(main())

My guess is that your mistake is using the Elasticsearch client class, which is synchronous. You should use AsyncElasticsearch.