新增测试文件

user_data.py

@@ -19,7 +19,7 @@ def get_user():
     sql = "select user_id,phone,name,city_id,channel,auth_type from api_userextra"
     df = pd.DataFrame(list(get_mysql_data(host,port,user,passwd,db,sql)))
     df = df.rename(columns={0: "user_id", 1: "phone",2:"name",3:"city_id",4:"channel",5:"auth_type"})
-    df.tosql("user", con=yconnect, if_exists='append',chunksize = 2000)
+    df.to_sql("user", con=yconnect, if_exists='append',chunksize = 2000)
     # l = 0
     # r = 2000
     # length = len(df)
@@ -32,7 +32,7 @@ def get_user():
 
 
 def get_device():
-    sql = "select device_id,platform,version,model,screen,channel,idfv from "
+    sql = "select device_id,platform,version,model,screen,channel,idfv from statistic_device"
 
 
 if __name__ == "__main__":