elasticsearch
copied
Update es
@ -34,6 +34,8 @@ class ESSearch(PyOperator):
raise e
def __call__(self, index_name: str, query: dict = {'match_all': {}}):
if not query:
return ''
resp = self.client.search(index=index_name, query=query)
return resp