TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-04 16:00:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化指标数据清理

Browse Source
This commit is contained in:
GoEdgeLab
2021-12-03 12:16:00 +08:00
parent f32c97a85b
commit 2f2dc1f45b
2 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
internal/db/models/metric_stat_dao.go
View File

@@ -481,6 +481,7 @@ func (this *MetricStatDAO) Clean(tx *dbs.Tx) error {
_, err := this.Query(tx). _, err := this.Query(tx).
Attr("itemId", item.Id). Attr("itemId", item.Id).
Lte("createdDay", expiresDay). Lte("createdDay", expiresDay).
UseIndex("createdDay").
Limit(100_000). // 一次性不要删除太多，防止阻塞其他操作 Limit(100_000). // 一次性不要删除太多，防止阻塞其他操作
Delete() Delete()
if err != nil { if err != nil {

1
internal/db/models/metric_sum_stat_dao.go
View File

@@ -188,6 +188,7 @@ func (this *MetricSumStatDAO) Clean(tx *dbs.Tx) error {
Attr("itemId", item.Id). Attr("itemId", item.Id).
Where("(createdDay IS NULL OR createdDay<:day)"). Where("(createdDay IS NULL OR createdDay<:day)").
Param("day", expiresDay). Param("day", expiresDay).
UseIndex("createdDay").
Limit(100_000). // 一次性不要删除太多，防止阻塞其他操作 Limit(100_000). // 一次性不要删除太多，防止阻塞其他操作
Delete() Delete()
if err != nil { if err != nil {