修改luj

eda/esmm/Model_pipline/to_database.py

@@ -5,6 +5,7 @@ import pandas as pd
 import pymysql
 import datetime
 
+
 def con_sql(sql):
     """
     :type sql : str
@@ -77,7 +78,7 @@ def main():
         # df_merge = df_all[['device_id','city_id']].apply(lambda x: ''.join(x),axis=1)
 
         delete_str = 'delete from esmm_device_diary_queue where concat(device_id,city_id) in ({0})'.format(df_merge_str)
-        con = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+        con = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test',cursorclass=pymysql.cursors.DictCursor)
         cur = con.cursor()
         cur.execute(delete_str)
         con.commit()