From 716810adb573f7e6b40ab52887b5b158d9824817 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 16 九月 2019 17:04:03 +0800
Subject: [PATCH] 读公共的配置文件

---
 main.go |    7 ++++---
 1 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/main.go b/main.go
index 411d714..5a4d7ea 100644
--- a/main.go
+++ b/main.go
@@ -7,7 +7,6 @@
 	"net/http"
 	_ "net/http/pprof"
 	"ruleprocess/insertdata"
-	"ruleprocess/labelFilter"
 	"ruleprocess/util"
 	"time"
 
@@ -31,12 +30,14 @@
 var surveyPort = flag.Int("surveyPort", 40007, "survey port") //蹇冭烦
 var pubPort = flag.Int("pubPort", 50007, "pubsub port")       //鏁版嵁鏇存柊
 var initchan = make(chan bool)
+var env =  flag.String("env","pro","env set")
 
 func init() {
+	flag.Parse()
 	// 鏃ュ織鍒濆鍖�
 	logger.Config("./info.log", logger.DebugLevel)
 	logger.Info("鏃ュ織鍒濆鍖栨垚鍔燂紒")
-
+	insertdata.Init(*env)
 }
 func main() {
 	//fmt.Println("缂撳瓨鍒濆鍖栧畬鎴�",<- initchan)//dbserver鍒濆鍖栧畬姣�
@@ -95,7 +96,7 @@
 					insertdata.InsertToEs(resultMsg)
 					logger.Debug("鎻掑叆瀹孍s鎵�鐢ㄦ椂闂达細", time.Since(start))
 					//浜嬩欢鎺ㄩ��
-					go labelFilter.Judge(resultMsg)
+					//go labelFilter.Judge(resultMsg)
 				//}(msg)
 			}
 		}

--
Gitblit v1.8.0