- def flush_result_data(self):
- LOG.debug('Test result all : %s',
- jsonutils.dump_as_bytes(self.raw_result))
- return 0
+ if not self.tags:
+ self.tags = {
+ 'deploy_scenario': os.environ.get('DEPLOY_SCENARIO', 'unknown'),
+ 'installer': os.environ.get('INSTALLER_TYPE', 'unknown'),
+ 'pod_name': os.environ.get('NODE_NAME', 'unknown'),
+ 'version': os.environ.get('YARDSTICK_BRANCH', 'unknown')
+ }
+
+ point = {
+ "measurement": case,
+ "fields": utils.flatten_dict_key(data["data"]),
+ "time": self._get_nano_timestamp(data),
+ "tags": self._get_extended_tags(criteria),
+ }
+ msg["points"] = [point]
+ msg["tags"] = self.tags
+
+ return make_lines(msg).encode('utf-8')
+
+ def _get_nano_timestamp(self, results):
+ try:
+ timestamp = results["timestamp"]
+ except KeyError:
+ timestamp = time.time()
+
+ return str(int(float(timestamp) * 1000000000))
+
+ def _get_extended_tags(self, criteria):
+ tags = {
+ "task_id": self.task_id,
+ "criteria": criteria
+ }
+
+ return tags