Compatible with elasticsearch-dsl

[digitaldavenyc]

Is it possible to use this with elasticsearch-dsl?

[0bsearch]

Not as drop-in replacement.

Dsl does a lot of sync calls, i.e. DocType.save() or Search.execute(). You need to subclass and change it to await calls from underlying async transport.

[udfalkso]

The DSL Search has a to_dict() method that you can then pass as the body to the async es client. Seems to work for me.

Something like this:

from elasticsearch_async import AsyncElasticsearch
es = AsyncElasticsearch(hosts=["localhost"])

q = # build your query
s = Search(index=INDEX_NAME).query(q)
r = await es.search(index=INDEX_NAME, body=s.to_dict())

[sethmlarson]

This issue is being tracked on the Elasticsearch-DSL repository here: elastic/elasticsearch-dsl-py#1355
Closing in favor of that issue.