SDK for Ruby を使用した Amazon MSK の例 - AWS SDK for Ruby
サーバーレスサンプル

SDK for Ruby を使用した Amazon MSK の例

次のコード例は、Amazon MSK で AWS SDK for Ruby を使用してアクションを実行し、一般的なシナリオを実装する方法を示しています。

各例には完全なソースコードへのリンクが含まれており、コードの設定方法と実行方法に関する手順を確認できます。

サーバーレスサンプル

次のコード例は、Amazon MSK クラスターからレコードを受信することによってトリガーされるイベントを受け取る Lambda 関数の実装方法を示しています。関数は MSK ペイロードを取得し、レコードの内容をログ記録します。

SDK for Ruby
注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Ruby を使用した Lambda での Amazon MSK イベントの消費。


require 'base64'

def lambda_handler(event:, context:)
  # Iterate through keys
  event['records'].each do |key, records|
    puts "Key: #{key}"

    # Iterate through records
    records.each do |record|
      puts "Record: #{record}"

      # Decode base64
      msg = Base64.decode64(record['value'])
      puts "Message: #{msg}"
    end
  end
end