fix(mongodb): 迁移元数据修复密码保存 TencentBlueKing#8129

yyhenryyy · Nov 22, 2024 · 90c1b50 · 90c1b50
1 parent e399964
commit 90c1b50
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/mongodb/mongodb_install_dbmon.py b/dbm-ui/backend/flow/engine/bamboo/scene/mongodb/mongodb_install_dbmon.py
@@ -169,7 +169,7 @@ def start(self):
         # parse iplist
         iplist = self.get_iplist(self.payload["infos"], bk_cloud_id=self.payload["bk_cloud_id"])
 
-        add_install_dbmon(self, self.payload, pipeline, iplist, self.payload["bk_cloud_id"])
+        add_install_dbmon(self.root_id, self.payload, pipeline, iplist, self.payload["bk_cloud_id"])
         # 运行流程
         pipeline.run_pipeline()
 

diff --git a/dbm-ui/backend/flow/utils/mongodb/migrate_meta.py b/dbm-ui/backend/flow/utils/mongodb/migrate_meta.py
@@ -132,7 +132,8 @@ def save_app_password(self):
                     operator="admin",
                 )
                 if info != "":
-                    logger.error("user:{} save password to db fail, error:{}".format(user, info))
+                    logger.error("user:{} save password:{} to db fail, error:{}".format(user, self.info[user], info))
+                    return False
 
     def save_password(self):
         """保存密码到密码服务"""
@@ -146,7 +147,12 @@ def save_password(self):
                     operator=self.info["operator"],
                 )
                 if result:
-                    logger.error("save password fail, error: {}".format(result))
+                    logger.error(
+                        "nodes:{} save user:{} password:{} fail, error: {}".format(
+                            password_info["nodes"], username, password_info["password"][username], result
+                        )
+                    )
+                    return False
 
     def change_domain_app(self):
         """修改dns的app字段"""