MSKAmazon-Beispiele SDK für die Verwendung von Ruby - AWS SDKfür Ruby
Serverless-Beispiele

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

MSKAmazon-Beispiele SDK für die Verwendung von Ruby

Die folgenden Codebeispiele zeigen Ihnen, wie Sie AWS SDK for Ruby mit Amazon Aktionen ausführen und allgemeine Szenarien implementierenMSK.

Jedes Beispiel enthält einen Link zum vollständigen Quellcode, in dem Sie Anweisungen zum Einrichten und Ausführen des Codes im Kontext finden.

Serverless-Beispiele

Das folgende Codebeispiel zeigt, wie eine Lambda-Funktion implementiert wird, die ein Ereignis empfängt, das durch den Empfang von Datensätzen aus einem MSK Amazon-Cluster ausgelöst wird. Die Funktion ruft die MSK Nutzdaten ab und protokolliert den Inhalt des Datensatzes.

SDKfür Ruby
Anmerkung

Es gibt noch mehr dazu GitHub. Das vollständige Beispiel sowie eine Anleitung zum Einrichten und Ausführen finden Sie im Repository mit Serverless-Beispielen.

Nutzung eines MSK Amazon-Events mit Lambda unter Verwendung von Ruby.


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