package main import ( "field_sync/config" "fmt" "jygit.jydev.jianyu360.cn/data_processing/common_utils/log" "jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb" "os" ) // 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() 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() }