|
@@ -64,11 +64,8 @@ def main(project, table):
|
|
click_pv_avg = click_pv_sum / len(ad_idea_data)
|
|
click_pv_avg = click_pv_sum / len(ad_idea_data)
|
|
view_pv_avg = view_pv_sum / len(ad_idea_data)
|
|
view_pv_avg = view_pv_sum / len(ad_idea_data)
|
|
param1 = int(click_pv_avg * 1.2)
|
|
param1 = int(click_pv_avg * 1.2)
|
|
- param2 = int(view_pv_avg)
|
|
|
|
- if param1 < param2:
|
|
|
|
- value = json.dumps([param1, param2])
|
|
|
|
- else:
|
|
|
|
- value = json.dumps([param2-1, param2])
|
|
|
|
|
|
+ param2 = int(view_pv_avg) - int(click_pv_avg)
|
|
|
|
+ value = json.dumps([param1, param2])
|
|
redis_helper.set_data_to_redis(key_name=key_name, value=value, expire_time=24 * 3600)
|
|
redis_helper.set_data_to_redis(key_name=key_name, value=value, expire_time=24 * 3600)
|
|
i += 1
|
|
i += 1
|
|
log_.info(f"to redis count: {i}")
|
|
log_.info(f"to redis count: {i}")
|