Commit ec7e5a24 authored by litaolemo's avatar litaolemo

update

parent 5b48f711
...@@ -146,7 +146,7 @@ for t in range(1, task_days): ...@@ -146,7 +146,7 @@ for t in range(1, task_days):
UNION ALL UNION ALL
SELECT DISTINCT device_id SELECT DISTINCT device_id
FROM dev_view.dim_device_user_staff --去除内网用户 FROM dim.dim_device_user_staff --去除内网用户
""".format(yesterday_str=yesterday_str) """.format(yesterday_str=yesterday_str)
print(sql_spam_pv_device_id) print(sql_spam_pv_device_id)
spam_pv_df = spark.sql(sql_spam_pv_device_id) spam_pv_df = spark.sql(sql_spam_pv_device_id)
......
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