class FirehoseIntegration::KinesisBulkJob

Public Instance Methods

perform(stream, data) click to toggle source
# File lib/firehose_integration/jobs/kinesis_bulk_job.rb, line 4
def perform(stream, data)
  client = Aws::Firehose::Client.new(region:'us-east-1')

  records = []
  data.each do |d|
    records << {
      data: "#{d}\n"
    }
  end

  params = {
    delivery_stream_name: stream,
    records: records
  }

  client.put_record_batch params
end