data_field_dispose/field_sync_1/init.go

package main

import (
	"field_sync/config"

	elastic "app.yhyue.com/moapp/jybase/es"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
)

// InitLog @Description
// @Author J 2022/7/26 15:30
// func InitLog() {
// 	logcfg := config.Conf.Log

// 	err := log.InitLog(
// 		log.Path(logcfg.LogPath),
// 		log.Level(logcfg.LogLevel),
// 		log.Compress(logcfg.Compress),
// 		log.MaxSize(logcfg.MaxSize),
// 		log.MaxBackups(logcfg.MaxBackups),
// 		log.MaxAge(logcfg.MaxAge),
// 		log.Format(logcfg.Format),
// 	)
// 	if err != nil {
// 		fmt.Printf("InitLog failed: %v\n", err)
// 		os.Exit(1)
// 	}
// }

func InitMgo() {
	MgoB = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.MongoB.Addr,
		DbName:      config.Conf.DB.MongoB.Dbname,
		Size:        config.Conf.DB.MongoB.Size,
		UserName:    config.Conf.DB.MongoB.User,
		Password:    config.Conf.DB.MongoB.Password,
	}
	MgoB.InitPool()

	MgoBP = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.MongoB.Addr,
		DbName:      "qfw",
		Size:        config.Conf.DB.MongoB.Size,
		UserName:    config.Conf.DB.MongoB.User,
		Password:    config.Conf.DB.MongoB.Password,
	}
	MgoBP.InitPool()

	MgoE = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.MongoE.Addr,
		DbName:      config.Conf.DB.MongoE.Dbname,
		Size:        config.Conf.DB.MongoE.Size,
		UserName:    config.Conf.DB.MongoE.User,
		Password:    config.Conf.DB.MongoE.Password,
	}
	MgoE.InitPool()

	MgoQ = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.MongoQ.Addr,
		DbName:      config.Conf.DB.MongoQ.Dbname,
		Size:        config.Conf.DB.MongoQ.Size,
		UserName:    config.Conf.DB.MongoQ.User,
		Password:    config.Conf.DB.MongoQ.Password,
	}
	MgoQ.InitPool()

	MgoP = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.MongoP.Addr,
		DbName:      config.Conf.DB.MongoP.Dbname,
		Size:        config.Conf.DB.MongoP.Size,
		UserName:    config.Conf.DB.MongoP.User,
		Password:    config.Conf.DB.MongoP.Password,
	}
	MgoP.InitPool()
}

func InitEs() {
	Es = elastic.NewEs("v7", config.Conf.DB.Es.Addr, 20, config.Conf.DB.Es.User, config.Conf.DB.Es.Password)
}