所以我将 Athena 与 Java 结合使用,并使用查询重用 12 小时。然而,有时我们在 Athena 中获取新数据,我们需要一种机制来强制查询不使用保存的结果,而是使用新数据并存储它。
几乎就像刷新一样,并通知 Athena 进行下一个查询,不要使用旧结果,而是查询更新的数据并存储它并从现在开始使用它。
但棘手的一点是查询是相同的,数据发生了变化。有人有什么想法吗?
Athena 将仅匹配逐字 SQL 以实现结果重用。
如果您知道基础数据已更改,您可以在查询的注释中添加唯一的符号序列(例如更改时间戳),并将其保留到下一次数据源修改。