Class: MovableInk::AWS

Inherits:
Object
  • Object
show all
Includes:
Athena, Autoscaling, EC2, ElastiCache, Route53, S3, SNS, SSM
Defined in:
lib/movable_ink/aws.rb,
lib/movable_ink/aws/s3.rb,
lib/movable_ink/aws/ec2.rb,
lib/movable_ink/aws/sns.rb,
lib/movable_ink/aws/ssm.rb,
lib/movable_ink/version.rb,
lib/movable_ink/aws/athena.rb,
lib/movable_ink/aws/errors.rb,
lib/movable_ink/aws/route53.rb,
lib/movable_ink/aws/autoscaling.rb,
lib/movable_ink/aws/elasticache.rb

Defined Under Namespace

Modules: Athena, Autoscaling, EC2, ElastiCache, Errors, Route53, S3, SNS, SSM

Constant Summary collapse

VERSION = 
'0.1.14'

Class Method Summary collapse

Instance Method Summary collapse

Methods included from ElastiCache

#all_elasticache_replicas, #elasticache, #elasticache_primary, #elasticache_replica_in_my_az, #replication_group

Methods included from S3

#directory_exists?, #s3

Methods included from Athena

#athena

Methods included from SSM

#extract_parameters, #get_role_secrets, #get_secret, #ssm

Methods included from Route53

#list_all_r53_resource_record_sets, #resource_record_sets, #route53

Methods included from Autoscaling

#autoscaling, #complete_lifecycle_action, #delete_role_tag, #keep_instance_alive, #mark_me_as_healthy, #mark_me_as_unhealthy, #record_lifecycle_action_heartbeat

Methods included from SNS

#notify_and_sleep, #notify_nsq_can_not_be_drained, #notify_slack, #sns, #sns_slack_topic_arn

Methods included from EC2

#all_instances, #assign_ip_address, #available_elastic_ips, #ec2, #elastic_ips, #instance_id, #instance_ip_addresses_by_role, #instance_ip_addresses_by_role_ordered, #instances, #load_all_instances, #load_mi_env, #load_thopter_instance, #me, #mi_env, #private_ip_addresses, #redis_by_role, #statsd_host, #thopter, #thopter_instance, #unassigned_elastic_ips

Constructor Details

#initialize(environment: nil, global_service: nil) ⇒ AWS

Returns a new instance of AWS.



36
37
38
39
40
41
42
 
# File 'lib/movable_ink/aws.rb', line 36

def initialize(environment: nil, global_service: nil)
  @mi_env = environment
  if global_service
    @availability_zone = 'us-east-1a'
    @instance_id = global_service
  end
end

Class Method Details

.regions ⇒ Object 



26
27
28
29
30
31
32
33
 
# File 'lib/movable_ink/aws.rb', line 26

def regions
  {
    'iad' => 'us-east-1',
    'rld' => 'us-west-2',
    'dub' => 'eu-west-1',
    'ord' => 'us-east-2'
  }
end

Instance Method Details

#availability_zone ⇒ Object 



78
79
80
81
82
83
84
 
# File 'lib/movable_ink/aws.rb', line 78

def availability_zone
  @availability_zone ||= begin
    az = `ec2metadata --availability-zone 2>/dev/null`.chomp
    raise(MovableInk::AWS::Errors::EC2Required) if az.empty?
    az
  end
end

#datacenter(region: my_region) ⇒ Object 



90
91
92
 
# File 'lib/movable_ink/aws.rb', line 90

def datacenter(region: my_region)
  regions.key(region)
end

#my_region ⇒ Object 



86
87
88
 
# File 'lib/movable_ink/aws.rb', line 86

def my_region
  @my_region ||= availability_zone.chop
end

#regions ⇒ Object 



74
75
76
 
# File 'lib/movable_ink/aws.rb', line 74

def regions
  self.class.regions
end

#run_with_backoff(quiet: false) ⇒ Object

Raises:



44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/movable_ink/aws.rb', line 44

def run_with_backoff(quiet: false)
  9.times do |num|
    begin
      return yield
    rescue Aws::EC2::Errors::RequestLimitExceeded,
           Aws::SNS::Errors::ThrottledException,
           Aws::AutoScaling::Errors::ThrottledException,
           Aws::S3::Errors::SlowDown,
           Aws::Route53::Errors::ThrottlingException,
           Aws::Route53::Errors::PriorRequestNotComplete,
           Aws::SSM::Errors::TooManyUpdates,
           Aws::Athena::Errors::ThrottlingException,
           MovableInk::AWS::Errors::NoEnvironmentTagError
      sleep_time = (num+1)**2 + rand(10)
      if quiet
        (num >=8) ? notify_and_sleep(sleep_time, $!.class) : sleep(sleep_time)
      else
        notify_and_sleep(sleep_time, $!.class)
      end
    rescue Aws::Errors::ServiceError => e
      message = "#{e.class}: #{e.message}\nFrom `#{e.backtrace.last.gsub("`","'")}`"
      notify_slack(subject: 'Unhandled AWS API Error',
                   message: message)
      puts message
      raise MovableInk::AWS::Errors::ServiceError
    end
  end
  raise MovableInk::AWS::Errors::FailedWithBackoff
end