從 Amazon MSK 觸發器調用 Lambda 函數

下列程式碼範例示範如何實作 Lambda 函數，該函數會接收透過從 Amazon MSK 叢集接收記錄而觸發的事件。該函數檢索MSK有效負載並記錄記錄內容。

JavaScript

SDK對於 JavaScript （3）

注意

還有更多關於 GitHub。尋找完整範例，並了解如何在無伺服器範例儲存庫中設定和執行。

消費 Amazon MSK 事件 Lambda 使用 JavaScript.

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

exports.handler = async (event) => {
    // Iterate through keys
    for (let key in event.records) {
      console.log('Key: ', key)
      // Iterate through records
      event.records[key].map((record) => {
        console.log('Record: ', record)
        // Decode base64
        const msg = Buffer.from(record.value, 'base64').toString()
        console.log('Message:', msg)
      }) 
    }
}