把数据库改成腾讯云

eda/esmm/Model_pipline/feature.py

@@ -62,7 +62,7 @@ def get_data():
     df = df.drop("level2", axis=1)
 
     service_id = tuple(df["service_id"].unique())
-    db = pymysql.connect(host='rdsfewzdmf0jfjp9un8xj.mysql.rds.aliyuncs.com', port=3306, user='work',
+    db = pymysql.connect(host='172.16.30.143', port=3306, user='work',
                          passwd='BJQaT9VzDcuPBqkd', db='zhengxing')
     sql = "select s.id,d.hospital_id from api_service s left join api_doctor d on s.doctor_id = d.id " \
           "where s.id in {}".format(service_id)

eda/feededa/src/main/scala/com/gmei/temp_analysis.scala

@@ -725,7 +725,7 @@ object copy_database {
 
 
       import sc.implicits._
-      val stat_date = GmeiConfig.getMinusNDate(1)
+      val stat_date = GmeiConfig.getMinusNDate(6)
 //      val stat_date=param.date
       val partition_date = stat_date.replace("-","")
 
@@ -744,7 +744,7 @@ object copy_database {
        """.stripMargin
       )
 
-      GmeiConfig.writeToJDBCTable(new_data, "train_Knowledge_network_data", SaveMode.Overwrite)
+      GmeiConfig.writeToJDBCTable("jdbc:mysql://152.136.44.138:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",new_data, "train_Knowledge_network_data", SaveMode.Overwrite)
 
 
     }