Class: Process::Naf::LogArchiver

Inherits:
Application
  • Object
show all
Defined in:
app/models/process/naf/log_archiver.rb

Constant Summary collapse

NAF_JOBS_LOG_PATH = 
"#{::Naf::PREFIX_PATH}/#{::Naf.schema_name}/jobs/"
NAF_RUNNERS_LOG_PATH = 
"#{::Naf::PREFIX_PATH}/#{::Naf.schema_name}/runners/"
DATE_REGEX = 
/\d{8}_\d{6}/
LOG_RETENTION = 
1

Instance Method Summary collapse

Instance Method Details

#work ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'app/models/process/naf/log_archiver.rb', line 11

def work
	# Use AWS credentials to access S3
s3 = AWS::S3.new(access_key_id: AWS_ID,
                    secret_access_key: AWS_KEY,
                    ssl_verify_peer: false)

# Each project will have a specific bucket
bucket = s3.buckets[NAF_BUCKET]
   files = log_files

   logger.info 'Starting to save files to s3...'
   files.each do |file|
     # Write file if not existent
     object = bucket.objects["#{NAF_LOG_PATH}/#{creation_time}" + file[12..-1]]
     if !object.exists?
       # Write file to S3
       result = object.write(File.open(file).read)
       logger.info "File #{file} saved to S3"
     end
   end

   logger.info 'Starting to archive files...'
   archive_old_files(files)
end