我正在使用適用于 Java 的 AWS 開發工具包，其中我將數據從 AWS Lambda 發送到 SQS。我們得到了例外：Caused by: java.net.SocketException: Connection resetat java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:115)at java.net.SocketOutputStream.write(SocketOutputStream.java:155)at sun.security.ssl.OutputRecord.writeBuffer(OutputRecord.java:431)at sun.security.ssl.OutputRecord.write(OutputRecord.java:417)at sun.security.ssl.SSLSocketImpl.writeRecordInternal(SSLSocketImpl.java:886)at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:857)at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:123)at org.apache.http.impl.io.SessionOutputBufferImpl.streamWrite(SessionOutputBufferImpl.java:124)at org.apache.http.impl.io.SessionOutputBufferImpl.write(SessionOutputBufferImpl.java:160)at org.apache.http.impl.io.ContentLengthOutputStream.write(ContentLengthOutputStream.java:113)at org.apache.http.impl.io.ContentLengthOutputStream.write(ContentLengthOutputStream.java:120)at org.apache.http.entity.StringEntity.writeTo(StringEntity.java:167)at org.apache.http.impl.DefaultBHttpClientConnection.sendRequestEntity(DefaultBHttpClientConnection.java:156)at org.apache.http.impl.conn.CPoolProxy.sendRequestEntity(CPoolProxy.java:160)at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:238)at com.amazonaws.http.protocol.SdkHttpRequestExecutor.doSendRequest(SdkHttpRequestExecutor.java:63)at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272)at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:185)at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)背景我們正在嘗試做的事情：我們有一個主要的 Lambda 函數，它創建和初始化一個 SQS 隊列，并包含應處理的每條記錄的詳細信息?，F在需要設置 SQS 隊列以從隊列中創建 X 條消息的批次，并為每個批次自動調用另一個 SQS Lambda 函數。
3 回答
忽然笑
TA貢獻1806條經驗 獲得超5個贊
我們可以批量發送 10 個。工作代碼：
List<SendMessageBatchRequestEntry> sqsList= new LinkedList<SendMessageBatchRequestEntry>();
int batchId = 1; //To send a unique batchId for each msg in a batch
for (Metadata metadata: metadataList) {
String jsonString = new Gson().toJson(metadata);
if (sqsList.size() == 10) {
amazonSqs.sendMessageBatch(new SendMessageBatchRequest(queueUrl, sqsList));
sqsList.clear();
}
sqsList.add(new SendMessageBatchRequestEntry(batchId + "", jsonString));
batchId++;
}
if(sqsList.size()>0) {
amazonSqs.sendMessageBatch(new SendMessageBatchRequest(queueUrl, sqsList));
}
Helenr
TA貢獻1780條經驗 獲得超4個贊
似乎您的代碼很好，據我記得（我自己已經多次看到此錯誤），由于 SDK 如何重用 HTTP 連接，在使用 SDK 時會不時發生這種情況。此錯誤僅告訴您您的 Lambda 重置了 HTTP 連接，但 SDK 具有內置功能以重試失敗的請求，因此如果您在每個請求上都沒有看到此錯誤，您應該沒問題。
添加回答
舉報
0/150
提交
取消