打开推送功能

node/app/app.go

@@ -8,6 +8,7 @@ import (
 	"et_calc"
 	"et_calc/group"
 	"et_print"
+	"et_push"
 	"et_sink"
 	"fmt"
 	"gitea.anxinyun.cn/container/common_utils/configLoad"
@@ -106,8 +107,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
 }