|
@@ -114,19 +114,23 @@ module NeoInfra
|
|
|
region_conf = { region: region }
|
|
|
s = Fog::Storage.new(region_conf.merge(base_conf))
|
|
|
s.directories.each do |bucket|
|
|
|
- next unless bucket.location == region
|
|
|
- next unless Bucket.where(name: bucket.key).empty?
|
|
|
- vers = bucket.versioning?.to_s
|
|
|
- crea = bucket.creation_date.to_s
|
|
|
- b = Bucket.new(
|
|
|
- name: bucket.key,
|
|
|
- versioning: vers,
|
|
|
- creation: crea,
|
|
|
- size: cw.get_bucket_size(account[:key], account[:secret], bucket.location, bucket.key)
|
|
|
- )
|
|
|
- b.save
|
|
|
- BucketRegion.create(from_node: b, to_node: Region.where(region: bucket.location).first)
|
|
|
- BucketAccount.create(from_node: b, to_node: AwsAccount.where(name: account[:name]).first)
|
|
|
+ begin
|
|
|
+ next unless bucket.location == region
|
|
|
+ next unless Bucket.where(name: bucket.key).empty?
|
|
|
+ vers = bucket.versioning?.to_s
|
|
|
+ crea = bucket.creation_date.to_s
|
|
|
+ b = Bucket.new(
|
|
|
+ name: bucket.key,
|
|
|
+ versioning: vers,
|
|
|
+ creation: crea,
|
|
|
+ size: cw.get_bucket_size(account[:key], account[:secret], bucket.location, bucket.key)
|
|
|
+ )
|
|
|
+ b.save
|
|
|
+ BucketRegion.create(from_node: b, to_node: Region.where(region: bucket.location).first)
|
|
|
+ BucketAccount.create(from_node: b, to_node: AwsAccount.where(name: account[:name]).first)
|
|
|
+ rescue Exception => e
|
|
|
+ puts "ERROR: #{account[:name]}, #{region}, #{e.message}"
|
|
|
+ end
|
|
|
end
|
|
|
end
|
|
|
end
|