module.py 文件源码

def create_index(self,index):
        try:
            logger.debug("[elastic-logs] Creating index %s ...", index)
            self.es.indices.create(index)
        except ElasticsearchException, exp:
            logger.error("[elastic-logs] exception while creating index %s: %s", index, str(exp))