Skip to content

M
meta_base_code
Commit dfe253f3 authored by litaolemo's avatar litaolemo
Browse files
Options

update

parent bbcb3024
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
task/spark_test.py
View file @ dfe253f3
...@@ -132,6 +132,7 @@ SELECT * FROM online.bl_hdfs_maidian_updates ...@@ -132,6 +132,7 @@ SELECT * FROM online.bl_hdfs_maidian_updates
data = pandas.DataFrame(res_list) data = pandas.DataFrame(res_list)
data.to_csv("data.csv",encoding="gb18030") data.to_csv("data.csv",encoding="gb18030")
time.sleep(5)
from maintenance.send_email_with_file_auto_task import * 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") 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")
# sql_res = new_urser_device_id_df.collect() # sql_res = new_urser_device_id_df.collect()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment