修改esmm写入的数据表，用来测试

eda/esmm/Model_pipline/feature_engineering.py

@@ -340,6 +340,7 @@ def get_predict(date,value_map,app_list_map,leve2_map,leve3_map):
 
 
     rdd.persist(storageLevel= StorageLevel.MEMORY_ONLY_SER)
+    print("预测集样本大小：")
     print(rdd.count())
 
     spark.createDataFrame(rdd.filter(lambda x: x[0] == 0)

eda/esmm/Model_pipline/train.py

@@ -400,7 +400,7 @@ def update_or_insert(df2,queue_name):
     cur = con.cursor()
     try:
         for i in range(0, device_count):
-            query = """INSERT INTO esmm_device_diary_queue (device_id, city_id, time,%s) VALUES('%s', '%s', '%s', '%s') \
+            query = """INSERT INTO esmm_device_diary_queue_tmp (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])
             cur.execute(query)
             con.commit()