使用 Ruby SDK 的亚马逊MSK示例 - AWS SDK对于 Ruby
无服务器示例

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用 Ruby SDK 的亚马逊MSK示例

以下代码示例向您展示如何在 Amazon 中使用来执行操作和实现常见场景MSK。 AWS SDK for Ruby

每个示例都包含一个指向完整源代码的链接，您可以在其中找到有关如何在上下文中设置和运行代码的说明。

无服务器示例

以下代码示例说明如何实现 Lambda 函数，该函数接收通过从 Ama MSK zon 集群接收记录而触发的事件。该函数检索MSK有效载荷并记录记录内容。

SDK对于 Ruby
注意

还有更多相关信息 GitHub。在无服务器示例存储库中查找完整示例，并了解如何进行设置和运行。

使用 Ruby 在 Lambda 上使用亚马逊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