把阿里云数据库改成腾讯云数据库

eda/esmm/Model_pipline/feature.py

@@ -32,14 +32,14 @@ def multi_hot(df,column,n):
 
 
 def get_data():
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     sql = "select max(stat_date) from {}".format(train_data_set)
     validate_date = con_sql(db, sql)[0].values.tolist()[0]
     print("validate_date:" + validate_date)
     temp = datetime.datetime.strptime(validate_date, "%Y-%m-%d")
     start = (temp - datetime.timedelta(days=300)).strftime("%Y-%m-%d")
     print(start)
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     sql = "select e.y,e.z,e.stat_date,e.ucity_id,feat.level2_ids,e.ccity_name,u.device_type,u.manufacturer," \
           "u.channel,c.top,e.device_id,cut.time,dl.app_list,e.diary_service_id,feat.level3_ids,feat.level2 " \
           "from {} e left join user_feature u on e.device_id = u.device_id " \
@@ -55,7 +55,7 @@ def get_data():
                             6: "device_type", 7: "manufacturer", 8: "channel", 9: "top", 10: "device_id",
                             11: "time", 12: "app_list", 13: "service_id", 14: "level3_ids", 15: "level2"})
 
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     sql = "select level2_id,treatment_method,price_min,price_max,treatment_time,maintain_time,recover_time " \
           "from train_Knowledge_network_data"
     knowledge = con_sql(db, sql)
@@ -152,7 +152,7 @@ def write_csv(df,name,n):
 
 
 def get_predict(date,value_map,app_list_map,level2_map,level3_map):
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     sql = "select e.y,e.z,e.label,e.ucity_id,feat.level2_ids,e.ccity_name," \
           "u.device_type,u.manufacturer,u.channel,c.top,e.device_id,e.cid_id,cut.time," \
           "dl.app_list,e.hospital_id,feat.level3_ids,feat.level2 " \
@@ -167,7 +167,7 @@ def get_predict(date,value_map,app_list_map,level2_map,level3_map):
                             11: "cid_id", 12: "time", 13: "app_list", 14: "hospital_id", 15: "level3_ids",
                             16: "level2"})
 
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     sql = "select level2_id,treatment_method,price_min,price_max,treatment_time,maintain_time,recover_time " \
           "from train_Knowledge_network_data"
     knowledge = con_sql(db, sql)

eda/esmm/Model_pipline/to_database.py

@@ -10,7 +10,7 @@ def con_sql(sql):
     :type sql : str
     :rtype : tuple
     """
-    db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
     cursor = db.cursor()
     cursor.execute(sql)
     result = cursor.fetchall()
@@ -64,7 +64,7 @@ def main():
     df_all["time"] = ctime
     print("union_device_count",df_all.shape)
 
-    host='10.66.157.22'
+    host='172.16.40.158'
     port=4000
     user='root'
     password='3SYz54LS9#^9sBvC'
@@ -78,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='10.66.157.22', 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')
         cur = con.cursor()
         cur.execute(delete_str)
         con.commit()