change

user_data.py

@@ -87,6 +87,19 @@ def user_device_to_csv():
     df = df.rename(columns={0: "device_id", 1: "user_id"})
     df.to_csv('/tmp/csv/device_user.csv', index=False)
 
+def devcie_to_csv():
+    sql = "select device_id,platform,version,model,screen,channel,idfv from device"
+    df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
+    df = df.rename(columns={0: "device_id", 1: "platform", 2: "version", 3: "model", 4: "screen",
+                            5: "channel", 6: "idfv"})
+    df.to_csv('/tmp/csv/device.csv', index=False)
+
+
+def user_to_csv():
+    sql = "select user_id,phone,name,city_id,channel,auth_type from user"
+    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.to_csv('/tmp/csv/user.csv', index=False)
 
 
 if __name__ == "__main__":
@@ -102,7 +115,10 @@ if __name__ == "__main__":
     user = "root"
     passwd = "3SYz54LS9#^9sBvC"
     db = "jerry_test"
-    user_device_to_csv()
+    devcie_to_csv()
+    print("user ok")
+    user_to_csv()
+