renyupeng 1 năm trước cách đây
mục cha
commit
6184564c28

+ 1 - 1
spider/SpiderPromoterInfo.py

@@ -92,7 +92,7 @@ class SpiderPromoterInfo:
             SpiderPromoterInfo.get_promoter(promoter_id)
             SpiderPromoterInfo.get_promoter(promoter_id)
             SpiderPromoterInfo.r.srem('promoter_id_list', promoter_id)
             SpiderPromoterInfo.r.srem('promoter_id_list', promoter_id)
             time.sleep(3)
             time.sleep(3)
-
+        SpiderPromoterInfo.r.close()
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     SpiderPromoterInfo().get_promoter_info()
     SpiderPromoterInfo().get_promoter_info()

+ 1 - 0
spider/SpiderWeekPromoterInfo.py

@@ -97,6 +97,7 @@ class SpiderWeekPromoterInfo:
             self.get_promoter(promoter_id)
             self.get_promoter(promoter_id)
             self.r.srem('promoter_week_id_list', promoter_id)
             self.r.srem('promoter_week_id_list', promoter_id)
             time.sleep(1)
             time.sleep(1)
+        self.r.close()
 
 
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':

+ 3 - 5
utils/PromoterInfoWebHook.py

@@ -44,7 +44,7 @@ def webhook_get_promoter():
     if media_id == '2' or media_id is None:
     if media_id == '2' or media_id is None:
         if r.zcard('kuaishou_shop_click_token') == 0:
         if r.zcard('kuaishou_shop_click_token') == 0:
             cookie_update.get_click_coookie_to_redis()
             cookie_update.get_click_coookie_to_redis()
-            r.close()
+
 
 
 
 
         else:
         else:
@@ -76,7 +76,7 @@ def webhook_get_promoter():
                     p3.start()
                     p3.start()
                     p4.start()
                     p4.start()
                     p5.start()
                     p5.start()
-                    r.close()
+
                     return rollback
                     return rollback
 
 
                 else:
                 else:
@@ -115,7 +115,7 @@ def webhook_get_promoter():
                 p4.start()
                 p4.start()
                 p5.start()
                 p5.start()
                 r.zrem('kuaishou_shop_click_token', random_item[0])
                 r.zrem('kuaishou_shop_click_token', random_item[0])
-                r.close()
+
                 return roll
                 return roll
     else:
     else:
         rep = json.loads(request.data)
         rep = json.loads(request.data)
@@ -138,8 +138,6 @@ def webhook_update_promoter():
     promoterId = rep["promoterId"]
     promoterId = rep["promoterId"]
     if r.zcard('kuaishou_shop_click_token') == 0:
     if r.zcard('kuaishou_shop_click_token') == 0:
         cookie_update.get_click_coookie_to_redis()
         cookie_update.get_click_coookie_to_redis()
-        r.close()
-
     else:
     else:
         random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
         random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
         random_item = random.choice(random_member)
         random_item = random.choice(random_member)