Class: EbsSnapper::Ebs

Inherits:
Object
  • Object
show all
Defined in:
lib/ebs_snapper/ebs.rb

Defined Under Namespace

Classes: TTL

Constant Summary collapse

DEFAULT_TAG_NAME = 
'Snapper'

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ Ebs

Returns a new instance of Ebs.



21
22
23
24
25
26
27
28
29
 
# File 'lib/ebs_snapper/ebs.rb', line 21

def initialize(opts = {})
  AWS.config(
    :access_key_id => opts[:access_key_id],
    :secret_access_key => opts[:secret_access_key])
    
  @logger = opts[:logger] || Logger.new(STDOUT)
  @retain = opts[:retain]
  @tag_name = opts[:volume_tag] || DEFAULT_TAG_NAME # default
end

Instance Method Details

#each_region ⇒ Object 



81
82
83
84
85
 
# File 'lib/ebs_snapper/ebs.rb', line 81

def each_region
  ec2.regions.each do |region|
    yield (region)
  end
end

#ec2 ⇒ Object 



87
88
89
90
 
# File 'lib/ebs_snapper/ebs.rb', line 87

def ec2
  @ec2 ||= AWS::EC2.new
  @ec2
end

#purge_old_snapshots(ttl, region, vol_id) ⇒ Object 



68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/ebs_snapper/ebs.rb', line 68

def purge_old_snapshots(ttl, region, vol_id)
  region.snapshots.filter('volume-id', vol_id).filter('tag-key', @tag_name).each do |snapshot|
    unless snapshot.status == :pending
      ts = snapshot.tags[@tag_name]
      if ts > 0 && ttl.purge?(ts)
        @logger.info {"Purging #{vol_id} snapshot: #{snapshot}"}
        snapshot.delete
      end
    end
  end
end

#snapshot_and_purge ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/ebs_snapper/ebs.rb', line 31

def snapshot_and_purge
  # now snapshot the list
  tagged_volumes.each do |vol_info|
    snapshot_volume(vol_info[:region], vol_info[:volume_id])
    purge_old_snapshots(vol_info[:region], vol_info[:volume_id])
  end
end

#snapshot_volume(region, vol_id) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/ebs_snapper/ebs.rb', line 55

def snapshot_volume(region, vol_id)
  timestamp = Time.now.utc
  @logger.info {"Snapshotting #{vol_id} at: #{timestamp}"}
  vol = region.volumes[vol_id]
  if vol != nil
    snapshot = vol.create_snapshot("Snapper Backup #{timestamp}")
    # tag the snapshot with the timestamp so we can look it up later for cleanup
    snapshot.tag(@tag_name, :value => "#{timestamp.to_i}")
  else
    @logger.error "Error: Volume #{vol_id} in Region: #{region} not found"
  end
end

#tagged_volumes ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/ebs_snapper/ebs.rb', line 39

def tagged_volumes
  volumes = []
  
  each_region do |r|
    r.tags.filter('resource-type', 'volume').filter('key', @tag_name).each do |tag|
      # if the tag exists, it's using the default retention (TTL)
      volumes << {
        :ttl => TTL.new(@retain),
        :region => r,
        :volume_id => tag.resource.id # volume id
      }
    end
  end
  volumes
end