db_utils.py 397 B

123456789101112
  1. from urllib.parse import quote_plus
  2. from sqlalchemy import create_engine
  3. def create_sql_engine(config):
  4. user = config['user']
  5. passwd = quote_plus(config['password'])
  6. host = config['host']
  7. db_name = config['database']
  8. charset = config.get('charset', 'utf8mb4')
  9. engine = create_engine(f'mysql+pymysql://{user}:{passwd}@{host}/{db_name}?charset={charset}')
  10. return engine