index.py 文件源码

def search(self, body, **kwargs):
        assert 'index' not in kwargs
        if isinstance(body, string_types):
            pass
        else:
            body=elastify(body)
        tries = 0
        while True:
            tries += 1
            try:
                return self.esstore.es.search(
                    index=self.index_base,
                    body=body,
                    **kwargs)
            except ElasticsearchException as e:
                if (tries <= 1):
                    self.esstore.yellow()
                else:
                    raise ESError(e)