search.py 文件源码

def simple_search(self):
        """Perform URI-based request search.
        """
        accepted_params = ('q', 'df', 'default_operator', 'from', 'size')
        kwargs = {k: self.config[k] for k in accepted_params if self.config[k]}
        wl = curator.IndexList(self.client)
        indices = ','.join(wl.working_list())

        try:
            result = self.client.search(index=indices, **kwargs)
        except elasticsearch.ElasticsearchException as e:
            logger.error(e.message)
            sys.exit(2)

        if self._return_object:
            return True, result
        else:
            self._pp_exit(result)
            return None