使用 for Ruby SDK的 Amazon MSK範例 - AWS SDK 適用於 Ruby
無伺服器範例

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 for Ruby SDK的 Amazon MSK範例

下列程式碼範例示範如何使用 AWS SDK for Ruby 搭配 Amazon 執行動作和實作常見案例MSK。

每個範例都包含完整原始程式碼的連結，您可以在其中找到如何在內容中設定和執行程式碼的指示。

無伺服器範例

下列程式碼範例示範如何實作 Lambda 函數，該函數接收從 Amazon MSK叢集接收記錄所觸發的事件。函數會擷取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