【问题标题】:How DolphinDB clears historical data from distributed tables?DolphinDB如何从分布式表中清除历史数据?
【发布时间】:2019-06-15 12:26:40
【问题描述】:

我正在使用 DolphinDB 存储工厂设备生成的实时指标。有 1000 台设备,每台设备每秒生成 3000 个指标。我在 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 可以做到这一点吗?还是我需要 shell 脚本来执行此操作?

【问题讨论】:

    标签: database streaming distributed-system real-time-data dolphindb


    【解决方案1】:

    请使用函数dropPartition删除历史数据。

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2013-04-10
      • 2019-09-28
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-11-05
      • 1970-01-01
      • 2012-12-16
      相关资源
      最近更新 更多