Commit e51bebac authored by 张彦钊's avatar 张彦钊

crv feature file changed

parent 983c8525
...@@ -10,13 +10,9 @@ def get_data(): ...@@ -10,13 +10,9 @@ def get_data():
ctx = SQLContext(sc) ctx = SQLContext(sc)
# end_date = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y-%m-%d") # end_date = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y-%m-%d")
# start_date = (datetime.date.today() - datetime.timedelta(days=day)).strftime("%Y-%m-%d") # start_date = (datetime.date.today() - datetime.timedelta(days=day)).strftime("%Y-%m-%d")
dbtable = "select device_id,stat_date,ucity_id,cid_id,diary_service_id,y,z,clevel1_id," \ dbtable = "(select device_id,stat_date,ucity_id,cid_id,diary_service_id,y,z,clevel1_id," \
"slevel1_id,ccity_name,scity_id from jerry_prod.esmm_data jd " \ "slevel1_id,ccity_name,scity_id from jerry_prod.esmm_data jd " \
"inner join eagle.home_tab_click hk on jd.device_id = hk.device_id" "inner join eagle.home_tab_click hk on jd.device_id = hk.device_id)temp"
click = ctx.read.format("jdbc").options(url="jdbc:mysql://10.66.157.22:4000", click = ctx.read.format("jdbc").options(url="jdbc:mysql://10.66.157.22:4000",
driver="com.mysql.jdbc.Driver", driver="com.mysql.jdbc.Driver",
dbtable=dbtable, dbtable=dbtable,
......
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