Sha256: 8f9a5573af51b56ce731ad8e123664b6e16b50015c8ebcb8cca51aba5034fee5
Contents?: true
Size: 1.09 KB
Versions: 9
Compression:
Stored size: 1.09 KB
Contents
# Use to automatically create the CloudWatch group
module Ufo
class LogGroup
include AwsServices
def initialize(task_definition, options)
@task_definition, @options = task_definition, options
end
def create
puts "Ensuring log group for #{@task_definition} exists"
return if @options[:noop]
task_def = JSON.load(IO.read(task_def_path))
task_def["containerDefinitions"].each do |container_def|
begin
log_group_name = container_def["logConfiguration"]["options"]["awslogs-group"]
rescue NoMethodError
# silence when the logConfiguration is not specified
end
create_log_group(log_group_name) if log_group_name
end
end
def create_log_group(log_group_name)
resp = cloudwatchlogs.describe_log_groups(log_group_name_prefix: log_group_name)
exists = resp.log_groups.find { |lg| lg.log_group_name == log_group_name }
cloudwatchlogs.create_log_group(log_group_name: log_group_name) unless exists
end
def task_def_path
"./ufo/output/#{@task_definition}.json"
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems