|
@@ -144,7 +144,8 @@ func getTopicsOfNode(faultLabel string) (masterTopics []string, slaveTopics []st
|
|
|
// 判断是否可采集数据
|
|
|
func canCollect() bool {
|
|
|
// 如果开启了采集频率限制,则云端判断采集数量是否超过限额
|
|
|
- if commonConfig.LocalConfig.CollectLimitFlag == 1 {
|
|
|
+ if commonConfig.CloudConfig.CollectLimit.Flag == 1 {
|
|
|
+ c_log.GlobalLogger.Error("当前设备已开启数采频率限制,需判断采集数量是否达到限额。")
|
|
|
responseString, err := commonUtil.HttpPostJsonWithHeaders(
|
|
|
commonConfig.CloudConfig.CollectLimit.Url,
|
|
|
map[string]string{"Authorization": "U9yKpD6kZZDDe4LFKK6myAxBUT1XRrDM"},
|
|
@@ -171,6 +172,8 @@ func canCollect() bool {
|
|
|
c_log.GlobalLogger.Info("采集数量已超过限额,当前周期内不再采集。", resp.Code)
|
|
|
return false
|
|
|
}
|
|
|
+ } else {
|
|
|
+ c_log.GlobalLogger.Error("当前设备未开启数采频率限制,无需判断采集数量是否达到限额。")
|
|
|
}
|
|
|
|
|
|
// 本地判断是否存在正在处理的数据
|