'Connect to the Elasticsearch server.'

def _get_server(self):

    return elasticsearch.Elasticsearch((u'%s:%s' % (self.host, self.port)), retry_on_timeout=self.es_retry_on_timeout, max_retries=self.es_max_retries, timeout=self.es_timeout)
