def flush()

in CWMetricsToOpenSearch/es_sink/flushing_buffer.py [0:0]

• 20 lines of code
• 3 McCabe index (conditional complexity)

    def flush(self):
        '''Flushes the line_buffer, sending all to the _bulk API'''
        before_doc_count = self.buffer.es_doc_count()
        if self.buffer.es_doc_count() > 0:
            try:
                url = self.target_descriptor.bulk_url()
                print("Flushing {} documents {} to {}".format(
                    self.buffer.es_doc_count(),
                    time.time(),
                    url))
                result = self.transport.send('post', url, body=str(self.buffer))
                result = result._asdict()
                result['docs'] = self.buffer.es_doc_count()
                self.buffer.clear()
                return (before_doc_count, result)
            except Exception as exc:
                message = "Exception sending request '{}'"
                print(message.format(str(exc)))
                raise exc
        return (before_doc_count, None)