third/APIPark
1
0
Fork 0
mirror of https://github.com/APIParkLab/APIPark.git synced 2026-06-04 10:13:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix monitor bug

Browse Source
This commit is contained in:
Liujian
2025-04-30 00:24:02 +08:00
parent 4e459168df
commit 1d36f4b821
6 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/interface_to_all.go
+2
View File
@@ -29,6 +29,8 @@ func FmtIntFromInterface(val interface{}) int64 {
return int64(ret)
case int:
return int64(ret)
case float64:
return int64(ret)
default:
return 0
}
module/monitor/driver/influxdb-v2/executor.go
+1 -1
View File
@@ -446,7 +446,7 @@ func (e *executor) aggregateSummary(ctx context.Context, start time.Time, end ti
a.Avg = int64(v.(float64))
}
if v, ok := maxRes[field+"_max"]; ok {
a.Min = v.(int64)
a.Max = v.(int64)
}
if v, ok := minRes[field+"_min"]; ok {
a.Min = v.(int64)
module/monitor/driver/influxdb-v2/flux/flux.go
+1 -2
View File
@@ -159,8 +159,7 @@ func (f *fluxQuery) CommonTendency(ctx context.Context, queryApi api.QueryAPI, s
resultMap[field] = append(resultMap[field], common.FmtIntFromInterface(res[field]))
}
t, _ := res["_time"].(time.Time)
dates = append(dates, t)
dates = append(dates, t.In(time.Local))
}
return dates, resultMap, nil
module/monitor/driver/influxdb-v2/flux/tasks/day.yaml
+2 -1
View File
@@ -13,7 +13,8 @@
or
r._field == "timing" or r._field == "request" or r._field == "response" or r._field
==
"retry",
"retry"
or r._field == "total_token" or r._field == "input_token" or r._field == "output_token",
)
|> group(
columns: [
module/monitor/driver/influxdb-v2/flux/tasks/hour.yaml
+2 -1
View File
@@ -13,7 +13,8 @@
or
r._field == "timing" or r._field == "request" or r._field == "response" or r._field
==
"retry",
"retry"
or r._field == "total_token" or r._field == "input_token" or r._field == "output_token",
)
|> group(
columns: [
module/monitor/driver/influxdb-v2/flux/tasks/week.yaml
+2 -1
View File
@@ -13,7 +13,8 @@
or
r._field == "timing" or r._field == "request" or r._field == "response" or r._field
==
"retry",
"retry"
or r._field == "total_token" or r._field == "input_token" or r._field == "output_token",
)
|> group(
columns: [