Class: PumaCloudwatch::Metrics::Sender

Inherits:
Object
  • Object
show all
Defined in:
lib/puma_cloudwatch/metrics/sender.rb

Instance Method Summary collapse

Constructor Details

#initialize(metrics) ⇒ Sender

Returns a new instance of Sender.



14
15
16
17
18
19
20
21
22
23
 
# File 'lib/puma_cloudwatch/metrics/sender.rb', line 14

def initialize(metrics)
  @metrics = metrics
  @namespace = ENV['PUMA_CLOUDWATCH_NAMESPACE'] || "WebServer"
  @dimensions = calculate_dimensions
  @frequency = Integer(ENV['PUMA_CLOUDWATCH_FREQUENCY'] || 60)
  @enabled = ENV['PUMA_CLOUDWATCH_ENABLED'] || false
  @region = ENV['PUMA_CLOUDWATCH_AWS_REGION']
  @access_key_id = ENV['PUMA_CLOUDWATCH_AWS_ACCESS_KEY_ID']
  @secret_access_key = ENV['PUMA_CLOUDWATCH_AWS_SECRET_ACCESS_KEY']
end

Instance Method Details

#calculate_dimensions ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/puma_cloudwatch/metrics/sender.rb', line 25

def calculate_dimensions
  if ENV.key?('PUMA_CLOUDWATCH_DIMENSIONS')
    ENV['PUMA_CLOUDWATCH_DIMENSIONS'].split(',').map(&:strip).map do |dimension|
      name, value = dimension.split('=').map(&:strip)

      {
        name: name,
        value: value,
      }
    end
  else
    name = ENV['PUMA_CLOUDWATCH_DIMENSION_NAME'] || "App"
    value = ENV['PUMA_CLOUDWATCH_DIMENSION_VALUE'] || "puma"

    [
      name: name,
      value: value
    ]
  end
end

#call ⇒ Object 



46
47
48
49
50
51
 
# File 'lib/puma_cloudwatch/metrics/sender.rb', line 46

def call
  put_metric_data(
    namespace: @namespace,
    metric_data: metric_data,
  )
end

#metric_data ⇒ Object

Input @metrics example:

[{:backlog=>[0, 0],
:running=>[0, 0],
:pool_capacity=>[16, 16],
:max_threads=>[16, 16]}]

Output example:

[{:metric_name=>"backlog",
  :statistic_values=>{:sample_count=>2, :sum=>0, :minimum=>0, :maximum=>0}},
{:metric_name=>"running",
  :statistic_values=>{:sample_count=>2, :sum=>0, :minimum=>0, :maximum=>0}},
{:metric_name=>"pool_capacity",
  :statistic_values=>{:sample_count=>2, :sum=>32, :minimum=>16, :maximum=>16}},
{:metric_name=>"max_threads",
  :statistic_values=>{:sample_count=>2, :sum=>32, :minimum=>16, :maximum=>16}}]

Resources: pool_capcity and max_threads are the important metrics dev.to/amplifr/monitoring-puma-web-server-with-prometheus-and-grafana-5b5o



75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/puma_cloudwatch/metrics/sender.rb', line 75

def metric_data
  data = []
  @metrics.each do |metric|
    metric.each do |name, values|
      data << {
        metric_name: name.to_s,
        dimensions: @dimensions,
        storage_resolution: @frequency < 60 ? 1 : 60,
        statistic_values: {
          sample_count: values.length,
          sum: values.inject(0) { |sum, el| sum += el },
          minimum: values.min,
          maximum: values.max
        }
      }
    end
  end
  data
end