Contents

require "aws-logs"

module Ufo
  class Logs < Base
    include AwsService

    delegate :service, to: :info

    def run
      log = find_log_group_name
      puts "Showing logs for log group: #{log["awslogs-group"]} and stream prefix #{log["awslogs-stream-prefix"]}"
      if log
        cloudwatch_tail(log)
      else
        puts "Unable to find log group for service: #{service.service_name}"
      end
    end

    def find_log_group_name
      resp = ecs.describe_task_definition(task_definition: info.service.task_definition)

      container_definitions = resp.task_definition.container_definitions

      unless container_definitions.size == 1
        puts "ERROR: ufo logs command only supports 1 container definition in the ECS task definition".color(:red)
        return
      end

      definition = container_definitions.first
      log_conf = definition.log_configuration

      if log_conf && log_conf.log_driver == "awslogs"
        # options["awslogs-group"]
        # options["awslogs-region"]
        # options["awslogs-stream-prefix"]
        log_conf.options
      else
        puts "Only supports awslogs driver. Detected log_driver: #{log_conf.log_driver}"
        return
      end
    end

    def cloudwatch_tail(log={})
      o = {
        log_group_name: log["awslogs-group"],
        log_stream_name_prefix: log["awslogs-stream-prefix"],
        since: @options[:since] || "10m", # by default, search only 10 mins in the past
        follow: @options[:follow],
        format: @options[:format],
      }
      o[:filter_pattern] = @options[:filter_pattern] if @options[:filter_pattern]
      cw_tail = AwsLogs::Tail.new(o)
      cw_tail.run
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
ufo-5.0.7	lib/ufo/logs.rb
ufo-5.0.6	lib/ufo/logs.rb
ufo-5.0.5	lib/ufo/logs.rb
ufo-5.0.4	lib/ufo/logs.rb
ufo-5.0.3	lib/ufo/logs.rb
ufo-5.0.2	lib/ufo/logs.rb
ufo-5.0.1	lib/ufo/logs.rb
ufo-5.0.0	lib/ufo/logs.rb
ufo-4.6.3	lib/ufo/logs.rb
ufo-4.6.2	lib/ufo/logs.rb
ufo-4.6.1	lib/ufo/logs.rb