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