metrics.py 文件源码

def index(self, points):
        for p in points:
            p['_index'] = self.config['indexer']['idx_name']
            p['_type'] = self.es_type

        results = helpers.streaming_bulk(self.client, points)
        for status, r in results:
            if not status:
                log.debug("index err result %s", r)