ranklist

douyin_hourly_ranklist_commerce_scraper.py

@@ -241,9 +241,19 @@ def get_commerce_rank_list_data(room_id, sec_anchor_id, anchor_id, result):
 def scrape(room_id,sec_anchor_id,anchor_id):
     rds_list = RdsDouyinHourlyRankList()
 
+    key = 'DOUYIN_SCRAPE_DID_IID_TTREQ_1221'
+    rdid = DbRedis.connect().rpop(key)
+    if rdid:
+        result = rdid.split('@@@')
+    else:
+        result = []
+        return None
+
+    DbRedis.connect().lpush(key, rdid)
+
     try:
         # 带货小时榜
-        commerce_response_json = get_commerce_rank_list_data(room_id=room_id, sec_anchor_id=sec_anchor_id, anchor_id=anchor_id)
+        commerce_response_json = get_commerce_rank_list_data(room_id=room_id, sec_anchor_id=sec_anchor_id, anchor_id=anchor_id, result=result)
         
         if commerce_response_json is None:
             print(

douyin_hourly_ranklist_whole_scraper.py

@@ -241,13 +241,14 @@ def scrape(room_id,sec_anchor_id,anchor_id):
     if rdid:
         result = rdid.split('@@@')
     else:
+        result = []
         return None
 
     DbRedis.connect().lpush(key, rdid)
 
     try:
         # 全站小时榜
-        whole_station_response_json = get_whole_station_rank_data(room_id=room_id, sec_anchor_id=sec_anchor_id, anchor_id=anchor_id, result)
+        whole_station_response_json = get_whole_station_rank_data(room_id=room_id, sec_anchor_id=sec_anchor_id, anchor_id=anchor_id, result=result)
        
         if whole_station_response_json is None:
             print(