encoding parâmetro não funciona corretamente. Então, como @doru disse em este link , você deve adicionar
?charset=utf8mb4 no final da cadeia de conexão. assim:connect_string = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8mb4'.format(DB_USER, DB_PASS, DB_HOST, DB_PORT, DATABASE)
