Monosasi

Monosasi is a tool to manage Cloudwatch Events rules.

Installation

Add this line to your application's Gemfile:

gem 'monosasi'

And then execute:

$ bundle

Or install it yourself as:

$ gem install monosasi

Usage

export AWS_ACCESS_KEY_ID='...'
export AWS_SECRET_ACCESS_KEY='...'

# export rules to `Rulefile`
monosasi -e -o Rulefile

vi Rulefile

# apply `Rulefile` to Cloudwatch Events
monosasi -a --dry-run
monosasi -a

Help

Usage: monosasi [options]
    -k, --access-key ACCESS_KEY
    -s, --secret-key SECRET_KEY
    -r, --region REGION
        --profile PROFILE
        --credentials-path PATH
    -a, --apply
    -f, --file FILE
        --dry-run
    -e, --export
    -o, --output FILE
        --split
        --target REGEXP
        --include REGEXP
        --exclude REGEXP
        --no-color
        --debug

Note that now --target option is deprecated so it will be removed eventually. So consider use equivalent option --include instead of.

Rulefile example

require 'other/rulefile'

rule "cron" do
  state "ENABLED"
  description "my cron"
  schedule_expression "cron(0 17 ? * MON-FRI *)"
  target "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx" do
    arn "arn:aws:lambda:ap-northeast-1:123456789012:function:hello-world"
    input_path '$.detail'
  end
  target "yyyyyyyy-yyyy-yyyy-yyyy-yyyyyyyyyyyy" do
    arn "arn:aws:lambda:ap-northeast-1:123456789012:function:my-func"
  end
end

rule "ssm role" do
  state "ENABLED"
  event_pattern do
    {"detail-type"=>
      ["EC2 Command Invocation Status-change Notification",
       "EC2 Command Status-change Notification"],
     "source"=>["aws.ssm"]}
  end
  target "zzzzzzzz-zzzz-zzzz-zzzz-zzzzzzzzzzzz" do
    arn "arn:aws:lambda:ap-northeast-1:123456789012:function:trigger-func"
    input '{"foo": "bar"}'
  end
end

rule "esc-scheduled-task" do
  state "ENABLED"
  description "zzzzzzzz"
  schedule_expression "rate(30 minutes)"
  target "zzzzzzzzzz-zzzzzzz-zzzzzz" do
    arn "arn:aws:ecs:ap-northeast-1:33333333333:cluster/xxxxxxxxxxxxx"
    role_arn "arn:aws:iam::11111111:role/ecsEventsRole"
    input "{}"
    ecs_parameters ({
      :task_definition_arn => "arn:aws:ecs:ap-northeast-1:1111111111111:task-definition/xxxxxxxxxx:x",
      :task_count => 1000
    })
  end
end

rule "batch-scheduled-task" do
  state "ENABLED"
  description "zzzzzzzz"
  schedule_expression "rate(30 minutes)"
  target "zzzzzzzzzz-zzzzzzz-zzzzzz" do
    arn "arn:aws:batch:ap-northeast-1:33333333333:job-queue/xxxxxxxxxxxxx"
    role_arn "arn:aws:iam::11111111:role/xxxXxx"
    input "{}"
    batch_parameters ({
      :job_definition_arn => "arn:aws:batch:ap-northeast-1:1111111111111:job-definition/xxxxxxxxxx:x",
      :job_name => "zzzzzzzz"
    })
  end
end

rule "hako-console-ScaleSpotFleetByReservation-ap-northeast-1" do
  state "ENABLED"
  schedule_expression "rate(30 minutes)"
  target "zzzzzzzzzz-zzzzzzz-zzzzzz" do
    arn 'arn:aws:sqs:ap-northeast-1:33333333333:monosasi-events'
    input_transformer(
      input_paths_map: {
        'id' => '$.id',
        'time' => '$.time',
      },
      input_template: '{"id": <id>, "time": <time>, "message": "hello, world"}',
    )
  end
end

Similar tools

• Codenize.tools