@@ -100,6 +100,7 @@ func BagRecord(nodeName string) {
if signal == 3 { // 这个关闭是等待数据处理时的关闭
c_log.GlobalLogger.Error("采集数据,接收record命令进程关闭信号:", signal)
kill(recordProcessPid, recordSubProcessPid, cmd)
+ //entity.ProcessingFlag = true
continue
}
@@ -31,7 +31,8 @@ import (
)
var (
- triggerInterval = 3.0 // 每个触发器3秒触发一次
+ //triggerInterval = 3.0 // 每个触发器3秒触发一次
+ triggerInterval = 60.0 // 每个触发器60秒触发一次
logInterval = 3.0
logTime = time.Now()