【发布时间】:2021-08-17 11:32:49
【问题描述】:
我有一个名为 test 的表。每周一我将运行我的自动化脚本来将新 ID 添加到表中。
例如:如果我在 8 月 16 日星期一运行我的脚本..我应该只获得过去 7 天添加到测试表的新 ID。
结果不应包含 7 天之前添加的 id 因此,每周添加到表中的最近 7 天的新 ID 应该是结果
到目前为止,我正在传递这样的查询
select id,revision from fx_results.test where scoring_timestamp_utc >= '2021-08-01' and group by asset_id
python 脚本中的日期应该是动态的。
【问题讨论】:
标签: python sql datetime join apache-spark-sql