class DataFile
Public Class Methods
new(filename)
click to toggle source
# File lib/sqs_cli/data_file.rb, line 5 def initialize(filename) @filename = filename end
Public Instance Methods
read_batches() { |map { |message| count += 1 open_struct( message_id: count, body: strict_decode64) }| ... }
click to toggle source
# File lib/sqs_cli/data_file.rb, line 9 def read_batches count = 0 File.readlines(@filename).each_slice(10).each do |batch| yield (batch.map { |message| count += 1 OpenStruct.new( message_id: count.to_s, body: Base64.strict_decode64(message.strip) ) }) end end
write_batch(batch)
click to toggle source
# File lib/sqs_cli/data_file.rb, line 22 def write_batch(batch) File.open(@filename, "a") do |f| batch.each do |message| f.puts Base64.strict_encode64(message.body.strip) end end end