Pārlūkot izejas kodu

update 修改初始化logstash数据库

Alvin 8 mēneši atpakaļ
vecāks
revīzija
5d5869f2bc

+ 1 - 1
game/config/profile-gc.json

@@ -60,7 +60,7 @@
         "address": "",
         "__settings__": {
           "db_id_list": {
-            "game_db_id": "gc_logstash"
+            "logstash_db_id": "gc_logstash"
           },
           "ref_logger": "logstash_log"
         },

+ 3 - 3
game/game_cluster/internal/mdb/component.go

@@ -38,7 +38,7 @@ func (p *ActorDB) OnInit() {
 		dbID := p.App().Settings().GetConfig("db_id_list").GetString("game_db_id")
 		MDB = mongo.GetDb(dbID)
 		if MDB == nil {
-			clog.Panic("game_db_id not found")
+			clog.Panic("game_db_id not found, dbID:" + dbID)
 		}
 	}
 
@@ -49,10 +49,10 @@ func (p *ActorDB) OnInit() {
 		}
 
 		// 获取 db_id = "center_db_1" 的配置
-		dbID := p.App().Settings().GetConfig("db_id_list").GetString("game_db_id")
+		dbID := p.App().Settings().GetConfig("db_id_list").GetString("logstash_db_id")
 		LogstashDB = gormComponent.GetDb(dbID)
 		if LogstashDB == nil {
-			clog.Panic("game_db_id not found")
+			clog.Panic("logstash_db_id not found, dbID:" + dbID)
 		}
 
 		LogstashMigrateTables()