cloudwatch metrics can be turned off

README.md

@@ -171,6 +171,7 @@ config.lambdakiq
 - `max_retries=` - Retries for all jobs. Default is the Lambdakiq maximum of `12`.
 - `metrics_namespace=` - The CloudWatch Embedded Metrics namespace. Default is `Lambdakiq`.
 - `metrics_logger=` - Set to the Rails logger which is STDOUT via Lamby/Lambda.
+- `send_cloud_watch_metrics` - Set to `true` to enable CloudWatch metrics. Default is `true`.
 
 ### ActiveJob Configs
 

lib/lambdakiq/metrics.rb

@@ -17,6 +17,7 @@ def initialize(event)
 
     def log
       return unless lambdakiq?
+      return unless Lambdakiq.config.send_cloud_watch_metrics
       logger.info JSON.dump(message)
     end
 

lib/lambdakiq/railtie.rb

@@ -3,6 +3,7 @@ class Railtie < ::Rails::Railtie
     config.lambdakiq = ActiveSupport::OrderedOptions.new
     config.lambdakiq.max_retries = 12
     config.lambdakiq.metrics_namespace = 'Lambdakiq'
+    config.lambdakiq.send_cloud_watch_metrics = true
 
     config.after_initialize do
       config.active_job.logger = Rails.logger

test/cases/job_test.rb

@@ -43,6 +43,15 @@ class JobTest < LambdakiqSpec
     expect(metric['JobArg1']).must_equal 'test'
   end
 
+  it 'does not log cloudwatch embedded metrics when disabled' do
+    Lambdakiq.config.send_cloud_watch_metrics = false
+    response = Lambdakiq::Job.handler(event_basic(messageId: message_id))
+    assert_response response, failures: false
+    metric = logged_metric('perform.active_job')
+    expect(metric).must_be_nil
+    Lambdakiq.config.send_cloud_watch_metrics = true
+  end
+
   it 'must change message visibility to next value for failed jobs' do
     event = event_basic attributes: { ApproximateReceiveCount: '7' }, job_class: 'TestHelper::Jobs::ErrorJob', messageId: message_id
     response = Lambdakiq::Job.handler(event)