commit

aarch64/pjibot_delivery/master/package/service/produce_window.go

@@ -20,7 +20,11 @@ import (
 	"time"
 )
 
-var triggerInterval = 3.0 // 每个触发器3秒触发一次
+var (
+	triggerInterval = 3.0 // 每个触发器3秒触发一次
+	logInterval     = 3.0
+	logTime         = time.Now()
+)
 
 // PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
 func PrepareTimeWindowProducerQueue() {
@@ -54,7 +58,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -88,7 +95,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -122,7 +132,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -156,7 +169,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -190,7 +206,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -224,7 +243,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -258,7 +280,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -292,7 +317,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -326,7 +354,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -442,7 +473,6 @@ func canCollect() bool {
 		return false
 	}
 	if resp.Code != 200 { // 不是200 代表不允许采集
-		c_log.GlobalLogger.Infof("当前周期内采集数量已超过限额。%+v", resp)
 		return false
 	}
 	return true

aarch64/pjibot_guide/master/package/service/produce_window.go

@@ -15,7 +15,12 @@ import (
 	"time"
 )
 
-var triggerInterval = 3.0 // 每个触发器3秒触发一次
+var (
+	triggerInterval = 3.0 // 每个触发器3秒触发一次
+	logInterval     = 3.0
+	logTime         = time.Now()
+)
+
 // 负责监听所有主题并修改时间窗口
 func PrepareTimeWindowProducerQueue() {
 
@@ -47,7 +52,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}

aarch64/pjibot_patrol/master/package/service/produce_window.go

@@ -20,7 +20,12 @@ import (
 	"time"
 )
 
-var triggerInterval = 3.0 // 每个触发器3秒触发一次
+var (
+	triggerInterval = 3.0 // 每个触发器3秒触发一次
+	logInterval     = 3.0
+	logTime         = time.Now()
+)
+
 // 负责监听所有主题并修改时间窗口
 func PrepareTimeWindowProducerQueue() {
 
@@ -53,7 +58,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -87,7 +95,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -121,7 +132,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -155,7 +169,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -189,7 +206,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -223,7 +243,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -257,7 +280,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -291,7 +317,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -325,7 +354,10 @@ func PrepareTimeWindowProducerQueue() {
 										saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
 										break
 									} else {
-										c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										if time.Since(logTime).Seconds() > logInterval {
+											logTime = time.Now()
+											c_log.GlobalLogger.Errorf("触发事件【%v】，但当前周期内采集数量已超限额，不再采集。", faultLabel)
+										}
 									}
 								}
 							}
@@ -441,7 +473,6 @@ func canCollect() bool {
 		return false
 	}
 	if resp.Code != 200 { // 不是200 代表不允许采集
-		c_log.GlobalLogger.Infof("当前周期内采集数量已超过限额。%+v", resp)
 		return false
 	}
 	return true