|
|
@@ -61,7 +61,12 @@ def main(project, table):
|
|
|
continue
|
|
|
# 更新均值
|
|
|
key_name = f"{config_.THOMPSON_PARAM_KEY_PREFIX}-1"
|
|
|
- value = json.dumps([int(click_pv_sum * 1.2), view_pv_sum])
|
|
|
+ param1 = int(click_pv_sum * 1.2)
|
|
|
+ param2 = view_pv_sum
|
|
|
+ if param1 < param2:
|
|
|
+ value = json.dumps([param1, param2])
|
|
|
+ else:
|
|
|
+ value = json.dumps([param2-1, param2])
|
|
|
redis_helper.set_data_to_redis(key_name=key_name, value=value, expire_time=24 * 3600)
|
|
|
i += 1
|
|
|
log_.info(f"to redis count: {i}")
|
