From 15e33eadf7d37503438309bbd2b0a38d468a6c85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E7=99=BB=E6=95=B0?= <11035577+wu-dengshu@user.noreply.gitee.com> Date: Mon, 9 Dec 2024 15:09:54 +0800 Subject: [PATCH] =?UTF-8?q?milvus=20=E4=BF=AE=E6=94=B9=E5=88=86=E5=8C=BA?= =?UTF-8?q?=E5=86=99=E5=85=A5=E6=B5=8B=E8=AF=95=E7=89=88=E6=9C=ACv1.2=20?= =?UTF-8?q?=E4=BF=AE=E4=B8=BA=E4=B8=BA=E6=AF=8F=E6=AC=A1=E5=88=A0=E9=99=A4?= =?UTF-8?q?=E5=89=8D=E9=9D=A2=E6=89=80=E6=9C=89=E7=9A=84=E5=88=86=E5=8C=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- zzb_data_prod/Mil_unit.py | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) 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]: # 保留默认分区