亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

使用 java 的 AWS Kinesis Lambda 轉換 - 未返回一個或多個記錄 ID

使用 java 的 AWS Kinesis Lambda 轉換 - 未返回一個或多個記錄 ID

蕪湖不蕪 2023-10-13 09:50:12
處理 AWS kinesis 時出現以下錯誤 - Lambda 函數到 S3One or more record Ids were not returned. Ensure that the Lambda function returns all received record Ids.以下是我的代碼片段。{        List<KinesisFirehoseOutputRecord> results = event.getRecords().stream()                .map(record -> {                    KinesisFirehoseOutputRecord outRec = new KinesisFirehoseOutputRecord();                    outRec.setRecordId(record.getRecordId());                    outRec.setData(record.getData());                    if (record.getData().toLowerCase().contains("moldovan")) {                        outRec.setResult("Ok");                    } else {                        outRec.setResult("Dropped");                    }                    return outRec;                }).collect(Collectors.toList());        return new KinesisFirehoseResponse(results);        }如果我刪除 if else 條件并添加 outRec.setResult("Ok");,它按預期工作正常。知道如何解決這個問題嗎?
查看完整描述

1 回答

?
慕的地10843

TA貢獻1785條經驗 獲得超8個贊

Firehose 在函數執行后進行檢查...處理的 recordID 數量等于發送到函數的 recordID。

檢查是對函數結束時返回的數組進行的。

如果您刪除流程中的任何元素,您必須分配狀態為已刪除。

查看完整回答
反對 回復 2023-10-13
  • 1 回答
  • 0 關注
  • 85 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號