Method: OpenC3::ReducerModel.add_file

Defined in:
lib/openc3/models/reducer_model.rb

.add_file(bucket_key) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/openc3/models/reducer_model.rb', line 33

def self.add_file(bucket_key)
  # Only reduce tlm files
  bucket_key_split = bucket_key.split('/')
  if bucket_key_split[2] == 'tlm'
    # bucket_key is formatted like STARTTIME__ENDTIME__SCOPE__TARGET__PACKET__TYPE.bin
    # e.g. 20211229191610578229500__20211229192610563836500__DEFAULT__INST__HEALTH_STATUS__rt__decom.bin
    _, _, scope, target, _ = File.basename(bucket_key).split('__')
    case bucket_key
    when /__decom\.bin.gz$/
      Store.sadd("#{scope}__#{target}__reducer__decom", bucket_key)
    when /__reduced_minute\.bin.gz$/
      Store.sadd("#{scope}__#{target}__reducer__minute", bucket_key)
    when /__reduced_hour\.bin.gz$/
      Store.sadd("#{scope}__#{target}__reducer__hour", bucket_key)
    end
    # No else clause because add_file is called with raw files which are ignored
  end
end