SDK for Ruby を使用する Amazon MSKの例 - AWS SDK Ruby の場合
サーバーレスサンプル

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

SDK for Ruby を使用する Amazon MSKの例

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

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

サーバーレスサンプル

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

SDK 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