diff --git a/zzb_data_prod/Mil_unit.py b/zzb_data_prod/Mil_unit.py index ea30889..d8bc2f7 100644 --- a/zzb_data_prod/Mil_unit.py +++ b/zzb_data_prod/Mil_unit.py @@ -10,10 +10,6 @@ def create_partition_by_hour(current_hour): collection_name = "pdf_measure_v4" collection = Collection(collection_name) - # 获取当前时间 - now = datetime.now() - - # 创建当前小时的分区 partition_name = f"partition_{current_hour}" if not collection.has_partition(partition_name): @@ -22,12 +18,9 @@ def create_partition_by_hour(current_hour): partition = collection.partition(partition_name) partition.load() - # 删除前2个小时的分区 - # 获取所有分区 partitions = collection.partitions - - # 删除所有分区(除了默认分区) + # 删除所有分区(除了默认分区和当前分区) for partition in partitions: name = partition.name if name not in ["_default", partition_name]: # 保留默认分区