AWS 文檔 AWS SDK示例 GitHub 回購中有更多SDK示例。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
從 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)
})
}
}