in CWMetricsToOpenSearch/es_sink/flushing_buffer.py [0:0]
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)