Contents

require 'aws-sdk-ec2'
require 'hashie/mash'
require 'logger'
require 'open-uri'
require 'json'
require 'timeout'

class Pec2Mash < ::Hashie::Mash
  disable_warnings if respond_to?(:disable_warnings)
end

module Pec2
  class Ec2

    def initialize(profile:)
      @logger = Logger.new(STDOUT)
      @ec2 = Aws::EC2::Client.new(get_param(profile))
    end

    def instances_hash(condition)
      filter = []
      condition.each do |key, value|
        filter << { name: "tag:#{key}", values: ["#{value}"] }
      end
      filter << { name: 'instance-state-name', values: ['running'] }
      @ec2.describe_instances(
        filters: filter
      ).data.to_h[:reservations].map { |instance| Pec2Mash.new(instance[:instances].first) }
    end

    def get_document
      JSON.parse(get_metadata('/latest/dynamic/instance-identity/document/'))
    end

    def get_metadata(path)
      begin
        result = {}
        Timeout.timeout(TIME_OUT) {
          body = open('http://169.254.169.254' + path).read
          return body
        }
        return result
      rescue Timeout::Error => e
        raise "not EC2 instance"
      end
    end

    private

    def get_param(profile)
      param = {}
      if profile
        param[:profile] = profile
      else
        param[:region] = if ENV['AWS_REGION']
          ENV['AWS_REGION']
        else
          Metadata.get_document['region']
        end
      end
      param
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
pec2-0.7.1	lib/pec2/ec2.rb
pec2-0.7.0	lib/pec2/ec2.rb