update

task/spark_test.py

@@ -134,7 +134,12 @@ SELECT *  FROM online.bl_hdfs_maidian_updates
     data.to_csv("data.csv",encoding="gb18030")
     time.sleep(10)
     from maintenance.send_email_with_file_auto_task import *
-    send_file_email("",'',sender="litao@igengmei.com",email_group=["litao@igengmei.com"],email_msg_body_str="test",title_str="test",cc_group=["litao@igengmei.com"],file="data.csv")
+    import zipfile
+
+    with zipfile.ZipFile("data.zip", 'w',zipfile.ZIP_DEFLATED) as zp:
+        zp.write("data.csv")
+
+    send_file_email("",'',sender="litao@igengmei.com",email_group=["litao@igengmei.com"],email_msg_body_str="test",title_str="test",cc_group=["litao@igengmei.com"],file="data.zip")
 #   sql_res = new_urser_device_id_df.collect()
 #   res_dict = {}
 #   portrait_dict = {