change train.py

eda/esmm/Model_pipline/train.py

@@ -371,7 +371,6 @@ def main(file_path):
     elif FLAGS.task_type == 'export':
         print("Not Implemented, Do It Yourself!")
 
-
 def trans(x):
     return str(x)[2:-1] if str(x)[0] == 'b' else x
 
@@ -383,7 +382,7 @@ def set_join(lst):
 
 def df_sort(result,queue_name):
     df = pd.DataFrame(result, columns=["uid", "city", "cid_id", "pctcvr"])
-    print(df.head(10))
+    # print(df.head(10))
     df['uid1'] = df['uid'].apply(trans)
     df['city1'] = df['city'].apply(trans)
     df['cid_id1'] = df['cid_id'].apply(trans)
@@ -402,7 +401,6 @@ def update_or_insert(df2,queue_name):
         for i in range(0, device_count):
             query = """INSERT INTO esmm_device_diary_queue_test (device_id, city_id, time,%s) VALUES('%s', '%s', '%s', '%s') \
             ON DUPLICATE KEY UPDATE device_id='%s', city_id='%s', time='%s', %s='%s'""" % (queue_name, df2.device_id[i],df2.city_id[i], df2.time[i], df2[queue_name][i], df2.device_id[i], df2.city_id[i], df2.time[i], queue_name, df2[queue_name][i])
-            print(query)
             cur.execute(query)
             con.commit()
         con.close()