修改mysql连接

Pyspark_job/utils/db_util.py

 import os
 import sys
 from enum import Enum
-
 from sqlalchemy import create_engine, text
 from datetime import datetime, timedelta
 from typing import Dict
 from sqlalchemy.engine import Engine
+from urllib.parse import quote_plus as urlquote
 
 sys.path.append(os.path.dirname(sys.path[0]))
 
@@ -34,8 +34,8 @@ class DBUtil(object):
     # mysql连接参数
     __mysql_host__ = "rm-wz9yg9bsb2zf01ea4yo.mysql.rds.aliyuncs.com"
     __mysql_port__ = "3306"
-    __mysql_username__ = "XP_Yswg2025_PY"
-    __mysql_pwd__ = "Xp_Yswg2025_Py300"
+    __mysql_username__ = "XP_Yswg2025"
+    __mysql_pwd__ = "Xp_Yswg2025@300"
 
     # pg连接参数正式库-h15
     __pgsql_host__ = "192.168.10.224"
@@ -302,7 +302,7 @@ class DBUtil(object):
         # 获取数据库连接
         elif conn['db_type'] == 'mysql':
             engine = create_engine(
-                f"mysql+pymysql://{conn['username']}:{conn['pwd']}@{conn['host']}:{conn['port']}/{conn['db_name']}",
+                f"mysql+pymysql://{conn['username']}:{urlquote(conn['pwd'])}@{conn['host']}:{conn['port']}/{conn['db_name']}",
                 pool_size=10,  # 连接池的大小
                 max_overflow=20  # 超出连接池大小之外可以创建的连接数
             )