blob: 96df432374a7d5a0ed23e0cb023838d6c402ba7e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
# frozen_string_literal: true
require "active_support/core_ext/string/conversions"
module QA
module Tools
module Ci
class TestMetrics
include Helpers
include Support::InfluxdbTools
def initialize(metrics_file_glob)
@metrics_file_glob = metrics_file_glob
end
def self.export(metrics_file_glob)
new(metrics_file_glob).export
end
# Export metrics to main bucket
#
# @return [void]
def export
return logger.warn("No files matched pattern '#{metrics_file_glob}'") if metrics_files.empty?
logger.info("Exporting #{metrics_data.size} entries to influxdb")
influx_client.create_write_api.write(data: metrics_data, bucket: INFLUX_MAIN_TEST_METRICS_BUCKET)
end
private
attr_reader :metrics_file_glob
# Metrics data files
#
# @return [Array]
def metrics_files
@metrics_files ||= Dir.glob(metrics_file_glob)
end
# Test metrics data
#
# @return [Array<Hash>]
def metrics_data
@metrics_data ||= metrics_files
.flat_map { |file| JSON.parse(File.read(file), symbolize_names: true) }
.map { |entry| entry.merge(time: entry[:time].to_time) }
end
end
end
end
end
|
