Как DolphinDB очищает исторические данные из распределенных таблиц? - PullRequest
1 голос
/ 15 июня 2019

Я использую 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 сделать это? Или мне нужны сценарии оболочки для этого?

1 Ответ

0 голосов
/ 27 июня 2019

Пожалуйста, используйте функцию dropPartition для удаления исторических данных.

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