i

tensnsorflow/to_database.py

@@ -81,21 +81,33 @@ def main():
         tmp = str(to_delete[start:end]).strip('[]')
         df_merge_str.append(tmp)
 
-    try:
-        for i in df_merge_str:
-            delete_str = 'delete from esmm_device_diary_queue where concat(device_id,city_id) in ({0})'.format(i)
-            con = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
-            cur = con.cursor()
-            cur.execute(delete_str)
-            con.commit()
-            print("delete done")
-            con.close()
-        engine = create_engine(str(r"mysql+pymysql://%s:" + '%s' + "@%s:%s/%s") % (user, password, host, port, db))
-        df_all.to_sql('esmm_device_diary_queue',con=engine,if_exists='append',index=False,chunksize=8000)
-        print("insert done")
-
-    except Exception as e:
-        print(e)
+    for i in df_merge_str:
+        delete_str = 'delete from esmm_device_diary_queue where concat(device_id,city_id) in ({0})'.format(i)
+        con = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+        cur = con.cursor()
+        cur.execute(delete_str)
+        con.commit()
+        print("delete done")
+        con.close()
+    engine = create_engine(str(r"mysql+pymysql://%s:" + '%s' + "@%s:%s/%s") % (user, password, host, port, db))
+    df_all.to_sql('esmm_device_diary_queue', con=engine, if_exists='append', index=False, chunksize=8000)
+    print("insert done")
+
+    # try:
+    #     for i in df_merge_str:
+    #         delete_str = 'delete from esmm_device_diary_queue where concat(device_id,city_id) in ({0})'.format(i)
+    #         con = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    #         cur = con.cursor()
+    #         cur.execute(delete_str)
+    #         con.commit()
+    #         print("delete done")
+    #         con.close()
+    #     engine = create_engine(str(r"mysql+pymysql://%s:" + '%s' + "@%s:%s/%s") % (user, password, host, port, db))
+    #     df_all.to_sql('esmm_device_diary_queue',con=engine,if_exists='append',index=False,chunksize=8000)
+    #     print("insert done")
+    #
+    # except Exception as e:
+    #     print(e)
 
 
 if __name__ == '__main__':