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={})
      since = @options[:since] || "10m" # by default, search only 10 mins in the past
      cw_tail = AwsLogs::Tail.new(
        log_group_name: log["awslogs-group"],
        log_stream_name_prefix: log["awslogs-stream-prefix"],
        since: since,
        follow: @options[:follow],
        format: @options[:format],
      )
      cw_tail.run
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ufo-4.6.0	lib/ufo/logs.rb