Commit bbddffd9 authored by litaolemo's avatar litaolemo

update

parent 17ddb72a
...@@ -183,7 +183,7 @@ WHERE spam_pv.device_id IS NULL ...@@ -183,7 +183,7 @@ WHERE spam_pv.device_id IS NULL
maidian_sql = """select t1.device_id,t2.track as track from maidian_sql = """select t1.device_id,t2.track as track from
(select device_id from device_id_view)t1 (select device_id from device_id_view)t1
left join left join
(select cl_id, concat_ws(',', collect_list(action )) as track from (select cl_id, concat_ws(',', collect_list(action)) as track from
(select * from online.bl_hdfs_maidian_updates where partition_date = {partition_date} and cl_id is not null ) group by cl_id) t2 (select * from online.bl_hdfs_maidian_updates where partition_date = {partition_date} and cl_id is not null ) group by cl_id) t2
on t1.device_id = t2.cl_id""".format(partition_date=yesterday_str) on t1.device_id = t2.cl_id""".format(partition_date=yesterday_str)
print(maidian_sql) print(maidian_sql)
...@@ -194,7 +194,7 @@ on t1.device_id = t2.cl_id""".format(partition_date=yesterday_str) ...@@ -194,7 +194,7 @@ on t1.device_id = t2.cl_id""".format(partition_date=yesterday_str)
print("-------------------------------") print("-------------------------------")
for count, res in enumerate(sql_res): for count, res in enumerate(sql_res):
# print(count, res) print(count, res)
track = res.track track = res.track
track_list = track.split(",") track_list = track.split(",")
for one_key_word in track_list: for one_key_word in track_list:
......
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