xg

udpcreateindex/src/config.json

@@ -4,12 +4,12 @@
     "mongodb": {
         "addr": "192.168.3.207:27092",
         "pool": 10,
-        "db": "mxs"
+        "db": "qfw_data"
     },
 	"savedb": {
         "addr": "192.168.3.207:27092",
         "size": 10,
-        "db": "mxs"
+        "db": "qfw_data"
     },
     "jkmail": {
         "to":"zhangjinkun@topnet.net.cn",
@@ -56,9 +56,9 @@
     "filelength": 50000,
     "detaillength": 50000,
     "project": {
-        "db": "mxs",
-        "collect": "test",
-        "index": "projectset",
+        "db": "qfw_data",
+        "collect": "projectset",
+        "index": "projectset_v6",
         "type": "projectset"
     },
     "project2": {
@@ -99,7 +99,7 @@
 		}
     },
     "elastic": {
-        "addr": "http://127.0.0.1:9800",
+        "addr": "http://192.168.3.128:9800",
         "pool": 12
     }
 }

udpcreateindex/src/projectindex.go

@@ -173,7 +173,7 @@ func projectTask(data []byte, project, mapInfo map[string]interface{}) {
 	}
 
 	if i > 0 {
-		util.Debug(arr)
+		//util.Debug(arr)
 		elastic.BulkSave(index, itype, &arr, true)
 	}
 	log.Println(mapInfo, "create project index...over", n)