备份-04-20

udpfilterdup/src/config.json

@@ -5,8 +5,8 @@
         "addr": "192.168.3.207:27092",
         "pool": 10,
         "db": "zhengkun",
-        "extract": "all_01_02_fusiontest",
-        "extract_back": "all_01_02_fusiontest",
+        "extract": "repeat_test",
+        "extract_back": "repeat_test",
         "site": {
             "dbname": "zhengkun",
             "coll": "site"
@@ -15,7 +15,7 @@
     "task_mongodb": {
         "task_addrName": "192.168.3.207:27092",
         "task_dbName": "zhengkun",
-        "task_collName": "zk_data",
+        "task_collName": "repeat_test",
         "pool": 10
     },
     "jkmail": {

udpfilterdup/src/main.go

@@ -59,7 +59,6 @@ var (
 
 
 func init() {
-	
 	flag.StringVar(&lastid, "id", "", "增量加载的lastid") //增量
 	flag.StringVar(&gtid, "gtid", "", "历史增量的起始id")	//历史
 	flag.StringVar(&gtept, "gtept", "", "全量gte发布时间")//全量区间pt
@@ -139,7 +138,10 @@ func init() {
 }
 
 
-func main() {
+func mainT() {
+	//exportFenLeiData()
+	//return
+
 	go checkMapJob()
 	updport := Sysconfig["udpport"].(string)
 	udpclient = mu.UdpClient{Local: updport, BufSize: 1024}
@@ -173,9 +175,7 @@ func main() {
 }
 
 //测试组人员使用
-func mainT() {
-
-
+func main() {
 	if TimingTask {
 		go historyTaskDay()
 		time.Sleep(99999 * time.Hour)