no message

Pyspark_job/utils/db_util.py

 import os
 import sys
 from enum import Enum
+from urllib.parse import quote_plus
 
 from sqlalchemy import create_engine, text
 from datetime import datetime, timedelta
@@ -306,8 +307,10 @@ class DBUtil(object):
             )
         # 获取数据库连接
         elif conn['db_type'] == 'mysql':
+            pwd = quote_plus(conn['pwd'])  # 对密码进行编码
             engine = create_engine(
-                f"mysql+pymysql://{conn['username']}:{conn['pwd']}@{conn['host']}:{conn['port']}/{conn['db_name']}",
+                # f"mysql+pymysql://{conn['username']}:{conn['pwd']}@{conn['host']}:{conn['port']}/{conn['db_name']}",
+                f"mysql+pymysql://{conn['username']}:{pwd}@{conn['host']}:{conn['port']}/{conn['db_name']}",
                 pool_size=10,  # 连接池的大小
                 max_overflow=20  # 超出连接池大小之外可以创建的连接数
             )