我有一个流处理应用程序,它不断地将数据摄取到 AWS Timestream。
当特定范围的数据被错误处理时,我尝试提出这种方法,因此我需要再次重新摄取它们并将已经处理的数据标记为已删除。
这样做的最佳方法是什么?
提前致谢。
您可以在重新摄取数据时使用版本字段。
当提供版本字段时,如果数据具有更高的版本,Timestream 会覆盖/更新数据。
参考:Timestream Developer Guide