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
	Es               *es.Elastic
	Index            string
	Itype            string
	EsFields         []string
	TaskTime         int
	Updatetime       int64
)
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)
	Es = &es.Elastic{
		S_esurl: econf["addr"].(string),
		I_size:  qu.IntAllDef(econf["pool"], 12),
	}
	Es.InitElasticSize()
	EsFields = qu.ObjArrToStringArr(econf["esfields"].([]interface{}))
	//TaskTime = qu.IntAll(Sysconfig["tasktime"])
	Updatetime = qu.Int64All(Sysconfig["updatetime"])

}

func main() {
	go SaveEs()

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