第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全，請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題，去搜搜看，總會(huì)有你想問(wèn)的

如何將 Kinesis Firehose 數(shù)據(jù)傳遞到 dynamodb 表？

如何將 Kinesis Firehose 數(shù)據(jù)傳遞到 dynamodb 表？

Kinesis Firehose 流接收消息。有一個(gè)選項(xiàng)可以持久保存到 S3 中，但我的用例是插入到 dynamodb 表中。Firehose 有一個(gè)啟用 Lambda 函數(shù)的選項(xiàng)。我應(yīng)該使用 Lambda 將插入邏輯寫(xiě)入 dynamodb 表嗎？這是正確的方法嗎？如果是這樣，那么如何使用用 Java 編寫(xiě)的 Lambda 將記錄插入到 DynamoDB 中。
查看完整描述

1 回答

?
ibeautiful

TA貢獻(xiàn)1993條經(jīng)驗(yàn) 獲得超6個(gè)贊

沒(méi)有將 Firehose 流數(shù)據(jù)插入 DynamoDB（例如 S3 或 Redshift）的標(biāo)準(zhǔn)方法。推薦的方法是執(zhí)行 Lambda 并將記錄插入到 DynamoDB 中。

使用dynamoDB.batchWriteItem或dynamoDB.putItem。

public String handleRequest(KinesisFirehoseEvent event, Context context)

? ? List<KinesisFirehoseEvent.Record> records = event.getRecords();

? ? for(KinesisFirehoseEvent.Record rec : records)

? ? {

? ? ? ? String recordId = rec.getRecordId();

? ? ? ? String data = StandardCharsets.UTF_8.decode(rec.getData()).toString();


? ? ? ? Item item = transformStringToItem(data);

? ? ? ? // Write the item to the table?

? ? ? ? table.putItem(item);

? ? }

? ? return "success";

}


查看完整回答
反對(duì) 回復(fù) 2023-10-19
  • 1 回答
  • 0 關(guān)注
  • 127 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

 幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

 公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)