0

我有一个流处理应用程序,它不断将数据摄取到 AWS Timestream。

当特定范围的数据处理不正确时,我尝试提出该方法,因此我需要再次重新摄取它们并将已经处理的数据标记为已删除。

最好的方法是什么?

提前致谢。

4

1 回答 1

0

您可以在重新摄取数据时使用版本字段。

当提供版本字段时,如果数据具有更高的版本,时间流将覆盖/更新数据。

参考:时间流开发人员指南

于 2021-02-05T06:37:03.250 回答