DolphinDB如何清除分布式表中历史数据?

我在dolphindb中创建了分布式表用来存储设备指标数据,分布式表按照如下脚本创建

db1 = database (, VALUE, 2013.01.01... 2018.12.31)
db2 = database (, RANGE, 1000* (1.10))
db = database ("dfs://DevMetricsDB", COMPO, [db1, db2])
db.createPartitionedTable(t, "metricsTb", `timestamp` devId)

考虑到磁盘空间有限,而数据量随着时间快速增长。我想可以定期从dolphindb从清理掉三个月前的数据。但是dolphindb的分布式表并不支持delete语句来删除数据,有什么解决办法吗?还是说我需要用shell脚本从物理文件层面来做清理?

阅读 3k
1 个回答

可以用dropPartition删除历史数据:

db = database ("dfs://DevMetricsDB")
start = today() - 100
end = today() - 90
dropPartition(db, start..end)

DolphinDB还通过数据保留策略(Retention Policy)提供了数据生命周期管理的能力,数据保留策略通过setRetentionPolicy 函数实现 。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进