关闭推送功能

node/app/app.go

@@ -8,7 +8,6 @@ import (
 	"et_calc"
 	"et_calc/group"
 	"et_print"
-	"et_push"
 	"et_sink"
 	"fmt"
 	"gitea.anxinyun.cn/container/common_utils/configLoad"
@@ -107,8 +106,8 @@ func addWorkStages(nodeStageManage *stages.StageManager) *stages.StageManager {
 	nodeStageManage.AddStages(stationAnalyzeHandler.GetStage())
 
 	// 数据推送
-	publishHandler := et_push.NewPushHandler()
-	nodeStageManage.AddStages(publishHandler.GetStage())
+	//publishHandler := et_push.NewPushHandler()
+	//nodeStageManage.AddStages(publishHandler.GetStage())
 	return nodeStageManage
 }