In this video tutorial, we’ll cover Kinesis Events and how to connect them up to AWS Lambda Functions with Ruby on Jets. We’ll build a Jets project from scratch with the kinesis_event declaration. We’ll deploy the application and test the Kinesis event. We’ll show you how simple it is to get started with Ruby on Jets and Kinesis Events.

Example

class DataJob < ApplicationJob
  kinesis_event "my-stream" # existing stream
  def file
    puts "event #{JSON.dump(event)}"
    puts "kinesis_data #{JSON.dump(kinesis_data)}"
  end
end

Command to Send Test Data

aws kinesis put-record --stream-name my-stream --partition-key 1 --data "hello world"

• Ruby on Jets Kinesis Events Docs
• The full source code is available on GitHub: tongueroo/jets-kinesis-example

Hope you’ve enjoyed this article. If you find AWS Lambda, Serverless and Ruby on Jets interesting, please give it ⭐️ on GitHub. I’d appreciate it. 👍

Jets Events Series

• IoT Button Events and AWS Lambda with Ruby on Jets
• S3 Events and AWS Lambda with Ruby on Jets