| 
														
															@@ -79,6 +79,9 @@ class PoolRecall(object): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															     def flow_pool_recall(self, size=10): 
														 | 
														
														 | 
														
															     def flow_pool_recall(self, size=10): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         """从流量池中获取视频""" 
														 | 
														
														 | 
														
															         """从流量池中获取视频""" 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        return [] 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        # 暂时关闭流量池 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        """ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         log_.info('====== flow pool recall') 
														 | 
														
														 | 
														
															         log_.info('====== flow pool recall') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         flow_pool_key = self.get_pool_redis_key('flow') 
														 | 
														
														 | 
														
															         flow_pool_key = self.get_pool_redis_key('flow') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         flow_pool_recall_result = [] 
														 | 
														
														 | 
														
															         flow_pool_recall_result = [] 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -139,6 +142,7 @@ class PoolRecall(object): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             idx += get_size 
														 | 
														
														 | 
														
															             idx += get_size 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         return flow_pool_recall_result[:size] 
														 | 
														
														 | 
														
															         return flow_pool_recall_result[:size] 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        """ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															     def check_video_counts(self, video_ids, flow_pool_mapping): 
														 | 
														
														 | 
														
															     def check_video_counts(self, video_ids, flow_pool_mapping): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         """ 
														 | 
														
														 | 
														
															         """ 
														 |