change

user_data.py

@@ -64,7 +64,7 @@ def get_du():
 def get_order():
     sql = "select user_id,service_id,created_time from api_order"
     df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
-    df = df.rename(columns={0: "device_id", 1: "service_id",2:"created_time"})
+    df = df.rename(columns={0: "user_id", 1: "service_id",2:"created_time"})
     print(df.shape)
     l = 0
     r = 10000
@@ -76,9 +76,9 @@ def get_order():
         print("insert done")
 
 def to_csv():
-    sql = "select user_id,service_id,created_time from meigou_order limit 6"
+    sql = "select device_id,service_id,created_time from meigou_order limit 6"
     df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
-    df = df.rename(columns={0: "device_id", 1: "service_id", 2: "created_time"})
+    df = df.rename(columns={0: "user_id", 1: "service_id", 2: "created_time"})
     df.to_csv('/tmp/csv/a.csv', index=False)