如何用AWS SDK v3 for NodeJS实现Kinesis的Fire-and-Forget模式？

问题解答 #

1. AWS SDK v3中是否有支持Fire-and-Forget的其他Kinesis命令？ #

没有专门针对Fire-and-Forget模式的Kinesis命令。不管是单条写入的PutRecordCommand还是批量写入的PutRecordsCommand，本质都是异步操作，返回Promise对象。Fire-and-Forget的实现核心不是依赖特定命令，而是调整对异步Promise的处理方式，避免等待响应。

2. 是否可通过Kinesis客户端配置实现无需await的调用？ #

Kinesis客户端本身没有直接配置可以跳过await，但可以通过以下两种安全方式实现Fire-and-Forget，避免触发Runtime.UnhandledPromiseRejection错误：

方式一：手动捕获Promise错误

移除await后，为Promise添加.catch()处理错误，确保拒绝状态被捕获，不会抛出未处理异常：

// 示例代码
kinesisClient.send(putRecordCommand).catch(error => {
  // 记录错误日志，无需等待处理完成
  console.error("Kinesis写入失败:", error);
});

这种方式下，Lambda会继续执行后续逻辑（如果存在），不会等待Kinesis的响应，达成Fire-and-Forget的效果。

补充注意事项

• Fire-and-Forget模式下无法同步确认Kinesis是否成功接收记录，需要接受一定的数据丢失风险，可通过CloudWatch监控Kinesis的写入指标（如PutRecord.Success）来排查异常。
• 优先使用PutRecordsCommand批量写入，相比单条的PutRecordCommand能降低网络IO开销，提升整体写入效率，更适合高吞吐量场景。

内容的提问来源于stack exchange，提问作者gokan