put cloudwatch logs

Gemfile

# frozen_string_literal: true

source "https://rubygems.org"

git_source(:github) {|repo_name| "https://github.com/#{repo_name}" }

gem "aws-sdk-cloudwatchlogs"

push.rb

# frozen_string_literal: true

require "aws-sdk-cloudwatchlogs"
require "json"

loop {
  data = {
    user_id: Random.rand(100),
    category: Random.rand(10),
    value: Random.rand(1000)
  }

  client = Aws::CloudWatchLogs::Client.new region: 'ap-northeast-1'
  stream = client.describe_log_streams(
    log_group_name: "kinesis-test",
  )

  event = client.put_log_events(
    log_group_name: "kinesis-test",
    log_stream_name: "ruby",
    log_events: [
      {
        timestamp: Time.now.to_i.to_s + "000",
        message: data.to_json
      }
    ],
    sequence_token: stream[0][0].upload_sequence_token
  )

  p event
  sleep 60
}