AsyncElasticsearchRetriever(
self,
index_name: Union[str, Sequence[str]],
body_func: Callable[[str], Dict],
*,
content_field: Optional[Union[str, Mapping[str, str]]] = None,
document_mapper: Optional[Callable[[Mapping], Document]] = None,
client: Optional[AsyncElasticsearch] = None,
es_url: Optional[str] = None,
es_cloud_id: Optional[str] = None,
es_user: Optional[str] = None,
es_api_key: Optional[str] = None,
es_password: Optional[str] = None
)