| 
					
				 | 
			
			
				@@ -137,6 +137,12 @@ def main(): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     log_.info("使用时间参数-日期:{},小时:{}".format(date, str(hour))) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if hour in ["00", "01", "02", "03"]: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         log_.info(f"hour={hour}不执行,直接返回。") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        partition = str(date) + str(hour) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        redis_helper.set_data_to_redis( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            key_name=REDIS_PREFIX + "partition", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            value=partition, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            expire_time=EXPIRE_TIME * 3 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        ) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     # 1 判断上游数据表是否生产完成 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     project = "loghubods" 
			 |