class FirehoseIntegration::KinesisJob
Public Instance Methods
perform(stream, data)
click to toggle source
# File lib/firehose_integration/jobs/kinesis_job.rb, line 4 def perform(stream, data) client = Aws::Firehose::Client.new(region:'us-east-1') params = { delivery_stream_name: stream, record: { data: "#{data}\n" } } client.put_record params end