jy-data-extract/forecast/es/main.go

package main

import (
	"mongodb"
	qu "qfw/util"
	es "qfw/util/elastic"
)

var (
	Sysconfig map[string]interface{} //配置文件
	Mgo       *mongodb.MongodbSim
	Dbname    string
	Dbcoll    string
	Es1, Es2  *es.Elastic
	Index     string
	Itype     string
	EsFields  []string
	TaskTime  int
	UpdateId  string
)
var EsSaveCache = make(chan map[string]interface{}, 5000)
var SP = make(chan bool, 5)

func init() {
	qu.ReadConfig(&Sysconfig)
	Dbname = Sysconfig["dbname"].(string)
	Dbcoll = Sysconfig["dbcoll"].(string)
	Mgo = &mongodb.MongodbSim{
		MongodbAddr: Sysconfig["mgodb"].(string),
		Size:        qu.IntAllDef(Sysconfig["dbsize"], 5),
		DbName:      Dbname,
		UserName:    Sysconfig["uname"].(string),
		Password:    Sysconfig["upwd"].(string),
	}
	Mgo.InitPool()
	//es
	econf := Sysconfig["elastic"].(map[string]interface{})
	Index = econf["index"].(string)
	Itype = econf["itype"].(string)
	//Es1 = &es.Elastic{
	//	S_esurl: econf["addr"].(string),
	//	I_size:  qu.IntAllDef(econf["pool"], 12),
	//}
	//Es1.InitElasticSize()
	Es2 = &es.Elastic{
		S_esurl: econf["addr1"].(string),
		I_size:  qu.IntAllDef(econf["pool"], 12),
	}
	Es2.InitElasticSize()
	EsFields = qu.ObjArrToStringArr(econf["esfields"].([]interface{}))
	//TaskTime = qu.IntAll(Sysconfig["tasktime"])
	UpdateId = qu.ObjToString(Sysconfig["updateid"])

}

func main() {
	go SaveEs()

	go TimeTask()
	//go SaveAll()
	//go SaveAdd()
	ch := make(chan bool, 1)
	<-ch
}