Commit 053e7e27 authored by 赵威's avatar 赵威

update click ids days

parent 186fcd66
...@@ -52,7 +52,7 @@ def get_tracate_click_data(spark, start, end): ...@@ -52,7 +52,7 @@ def get_tracate_click_data(spark, start, end):
where action = 'page_view' where action = 'page_view'
AND partition_date BETWEEN '{}' AND '{}' AND partition_date BETWEEN '{}' AND '{}'
AND page_name='user_post_detail' AND page_name='user_post_detail'
AND page_stay>=1 AND page_stay>=3
AND cl_id is not null AND cl_id is not null
AND cl_id != '' AND cl_id != ''
AND business_id is not null AND business_id is not null
...@@ -155,7 +155,7 @@ def get_device_click_tractate_ids_dict(click_df): ...@@ -155,7 +155,7 @@ def get_device_click_tractate_ids_dict(click_df):
if __name__ == "__main__": if __name__ == "__main__":
spark = get_spark("test") spark = get_spark("test")
click_df = get_tracate_click_data(spark, get_ndays_before_no_minus(30), get_ndays_before_no_minus(1)) click_df = get_tracate_click_data(spark, get_ndays_before_no_minus(180), get_ndays_before_no_minus(1))
click_df.show(5, False) click_df.show(5, False)
res_dict = get_device_click_tractate_ids_dict(click_df) res_dict = get_device_click_tractate_ids_dict(click_df)
......
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