change

user_data.py

@@ -75,15 +75,28 @@ def get_order():
         r += 10000
         print("insert done")
 
+def to_csv():
+    sql = "select user_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.to_csv('/tmp/csv/a.csv', index=False)
+
 
 if __name__ == "__main__":
-    host = "172.16.30.141"
-    port = 3306
-    user = "work"
-    passwd = "BJQaT9VzDcuPBqkd"
-    db = "zhengxing"
-    yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
-    get_order()
+    # host = "172.16.30.141"
+    # port = 3306
+    # user = "work"
+    # passwd = "BJQaT9VzDcuPBqkd"
+    # db = "zhengxing"
+    # yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
+    #
+    host = "172.16.40.170"
+    port = 4000
+    user = "root"
+    passwd = "3SYz54LS9#^9sBvC"
+    db = "jerry_test"
+    to_csv()
+