diff --git a/monitoring/monitoring_server/src/asapo_monitoring_server/main/main.go b/monitoring/monitoring_server/src/asapo_monitoring_server/main/main.go index 3d510612c2974b7063f29e6c5ff60ea9902da338..da0e764b373d9cf49e11bd6e6e5060b2218e0a57 100644 --- a/monitoring/monitoring_server/src/asapo_monitoring_server/main/main.go +++ b/monitoring/monitoring_server/src/asapo_monitoring_server/main/main.go @@ -102,16 +102,16 @@ func main() { // It creates two databases. normalDB := settings.InfluxDbDatabase avgDB := normalDB + "_avg" - //rpName := "one_day" + rpName := "one_day" cqName := "avg_values" postStrings := []string{ "CREATE DATABASE " + normalDB, "CREATE DATABASE " + avgDB, - //"CREATE RETENTION POLICY " + rpName + " ON " + normalDB + - // " DURATION 24h REPLICATION 1 DEFAULT", + "CREATE RETENTION POLICY " + rpName + " ON " + normalDB + + " DURATION 24h REPLICATION 1 DEFAULT", "CREATE CONTINUOUS QUERY " + cqName + " ON " + normalDB + " BEGIN" + " SELECT mean(*) INTO " + avgDB + - "..:MEASUREMENT FROM /.*/ GROUP BY time(12h) END", + "..:MEASUREMENT FROM /.*/ GROUP BY time(12h),* END", } for i := 0; i < len(postStrings); i++ { postTODB(postStrings[i], settings) diff --git a/monitoring/monitoring_server/src/asapo_monitoring_server/server/QueryServer.go b/monitoring/monitoring_server/src/asapo_monitoring_server/server/QueryServer.go index 158347cfe1bc7140fe7c2bfd32f6d46717fc2fda..8dcd8844f48983ea31af5db00a38139a8665d1b2 100644 --- a/monitoring/monitoring_server/src/asapo_monitoring_server/server/QueryServer.go +++ b/monitoring/monitoring_server/src/asapo_monitoring_server/server/QueryServer.go @@ -174,6 +174,11 @@ func generateFilterForAVGData(s *QueryServer, filter string) string { // Currently, there is only one modification needed so this is a bit redundant. filterModifications := make(map[string]string) filterModifications[s.settings.InfluxDbDatabase] = s.settings.InfluxDbDatabase + averageSuffix + filterModifications[dbMeasurementBrokerFileRequests] = "mean_" + dbMeasurementBrokerFileRequests + filterModifications[dbMeasurementFtsTransfers] = "mean_" + dbMeasurementFtsTransfers + filterModifications[dbMeasurementFileInput] = "mean_" + dbMeasurementFileInput + filterModifications[dbMeasurementRdsCacheMemoryUsage] = "mean_" + dbMeasurementRdsCacheMemoryUsage + filterModifications[dbMeasurementRdsFileRequests] = "mean_" + dbMeasurementRdsFileRequests alteredFilter := filter // Do all the filterModifications