| 
														
															@@ -241,10 +241,10 @@ class ConsumptionRecommend(object): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															     @classmethod 
														 | 
														
														 | 
														
															     @classmethod 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     def run(cls): 
														 | 
														
														 | 
														
															     def run(cls): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        logger.info(f"[处理] 开始获取redis数据") 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        logger.info(f"[内容分析] 开始获取redis数据") 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         data = RedisHelper().get_client().rpop(name = "task:carry_redis_by_nrfx") 
														 | 
														
														 | 
														
															         data = RedisHelper().get_client().rpop(name = "task:carry_redis_by_nrfx") 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         if not data: 
														 | 
														
														 | 
														
															         if not data: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            logger.info('[处理] 无待执行的扫描任务') 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            logger.info('[内容分析] 无待执行的扫描任务') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             return 
														 | 
														
														 | 
														
															             return 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         data = orjson.loads(data) 
														 | 
														
														 | 
														
															         data = orjson.loads(data) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         uid = str(uuid.uuid4()) 
														 | 
														
														 | 
														
															         uid = str(uuid.uuid4()) 
														 |