Merge "ES INFO output"
This commit is contained in:
commit
e0d54ac59f
@ -82,14 +82,9 @@ class Elastic(object):
|
|||||||
body=result,
|
body=result,
|
||||||
doc_type=_type,
|
doc_type=_type,
|
||||||
refresh=True)
|
refresh=True)
|
||||||
if self.workload == "shaker":
|
self.logger.debug("Pushed data to Elasticsearch to index {}"
|
||||||
self.logger.debug("Pushed data to Elasticsearch to index {}"
|
"and browbeat UUID {}".
|
||||||
" and browbeat UUID {}" .
|
format(self.index, result['browbeat_uuid']))
|
||||||
format(self.index, result['browbeat_uuid']))
|
|
||||||
else:
|
|
||||||
self.logger.info("Pushed data to Elasticsearch to index {}"
|
|
||||||
" and browbeat UUID {}" .
|
|
||||||
format(self.index, result['browbeat_uuid']))
|
|
||||||
return True
|
return True
|
||||||
except Exception as Err:
|
except Exception as Err:
|
||||||
self.logger.error("Error pushing data to Elasticsearch, going to retry"
|
self.logger.error("Error pushing data to Elasticsearch, going to retry"
|
||||||
|
Loading…
x
Reference in New Issue
Block a user