jy-data-extract/udpdataclear/udpSensitiveWords/util/config.go

package util

import (
	"google.golang.org/grpc"
	"gopkg.in/olivere/elastic.v1"
	"log"
	"net/http"
	"sensitiveWords.udp/proto_grpc"
)

func init() {
	log.SetFlags(log.Ldate | log.Ltime | log.Lmicroseconds | log.Lshortfile)
}
func InitC() {
	ReadConfig("./config.json", &Config)
	if len(Config) == 0 {
		log.Fatalln("init config err")
	}

	BiddingMgo = &MongodbSim{
		MongodbAddr: Config["bidding_mgo_addr"].(string),
		Size:        IntAll(Config["mongodbPoolSize"]),
		DbName:      "qfw",
		UserName:    Config["userName"].(string),
		PassWord:    Config["passWord"].(string),
	}
	BiddingMgo.InitPool()

	Client_Es ,_= elastic.NewClient(http.DefaultClient, "http://192.168.3.11:9800")


	es_type, es_index = Config["es_type"].(string),Config["es_index"].(string)

	Fields = Config["fields"].(map[string]interface{})
	FindBuyerC, FindAgencyC, FindWinnerC = Config["buyer_c"].(string), Config["agency_c"].(string), Config["winner_c"].(string)
	qaddrs := Config["query_addrs"].([]interface{})
	for i, v := range qaddrs {
		conn, err := grpc.Dial(v.(string), grpc.WithInsecure(), grpc.WithBlock())
		if err != nil {
			log.Fatalf("did not connect: %d %v", i, err)
		}
		c := proto_grpc.NewSensitiveWordsClient(conn)
		QAddrs = append(QAddrs, &c)
	}
}

var Config map[string]interface{}
var BiddingMgo *MongodbSim
var Fields map[string]interface{}
var FindBuyerC, FindAgencyC, FindWinnerC string
var QAddrs []*proto_grpc.SensitiveWordsClient
var es_type, es_index	string
var Client_Es  *elastic.Client