首次销量策略

live_promotion_detail_v1_sale_scraper.py

@@ -51,9 +51,10 @@ def scrape(request_data, heat):
             )
 
             if heat==0:
-                rds_list.add_request_params(request_data, heat)
-                print('首次失败重新插入 ' + request_data)
-                sys.exit(0)
+                if random.randint(0, 100) > 0:
+                    rds_list.add_request_params(request_data, heat)
+                    print('首次失败重新插入 ' + request_data)
+                    sys.exit(0)
 
             if heat>0:
                 if random.randint(0, 9) > 0:
@@ -76,17 +77,14 @@ def scrape(request_data, heat):
                 news_time = int(time.time()) + add_t
                 next_rds = promotion_id + '@' + product_id + '@' + uid + '@' + room_id + '@' + str(news_time) 
                 rds_list.push_middle_list(next_rds)
-                print('中间插入 ' + next_rds)
             else :
                 add_t = 1200
                 news_time = int(time.time()) + add_t
                 next_rds = promotion_id + '@' + product_id + '@' + uid + '@' + room_id + '@' + str(news_time) 
                 rds_list.push_last_list(next_rds)
-                print('末次插入 ' + next_rds)
 
         if (commodity_detail is None) or (commodity_detail == '') or ('real_sell_num' in commodity_detail)==False:
             sys.exit(0)
-            print('失败----- ')
 
         data = json.dumps({
             "data": commodity_detail,
@@ -101,7 +99,6 @@ def scrape(request_data, heat):
 
         rds_list.record_v1_score(1)
         rds_list.push_v1_data_list(data)
-        print('成功+++++ ')
     except Exception as e:
         rds_list.record_v1_score(0)
         rds_list.add_request_params(request_data, heat)