es.py 文件源码

def index(self, index, doc_type, body):
        """Store a document in Elasticsearch."""
        try:
            return self.es.index(
                index=index, doc_type=doc_type, body=body)
        except elasticsearch.ConnectionError as e:
            self.logger.exception(
                'Failed to log to elasticsearch: %s', e.error)
            return {}