要删除 Milvus 中的所有集合及其数据,你可以使用 pymilvus 提供的 drop_collection 方法。以下是一个完整的 Python 脚本,它会连接到 Milvus,列出所有集合,并逐个删除它们:

from pymilvus import connections, utility, Collection

# 连接到 Milvus
def connect_to_milvus(host="10.80.0.230", port="19530"):
    connections.connect("default", host=host, port=port)
    print(f"已连接到 Milvus 服务: {host}:{port}")

# 获取所有 collections 的名称
def list_collections():
    collection_names = utility.list_collections()
    print("当前 Milvus 中的 collections:", collection_names)
    return collection_names

# 删除指定 collection
def drop_collection(collection_name):
    from pymilvus import Collection
    collection = Collection(collection_name)
    collection.drop()
    print(f"集合 '{collection_name}' 已成功删除")

# 删除所有 collections
def drop_all_collections():
    collection_names = list_collections()
    for collection_name in collection_names:
        drop_collection(collection_name)

# 主函数
def main():
    # 连接到 Milvus
    connect_to_milvus()

    # 删除所有 collections
    drop_all_collections()

if __name__ == "__main__":
    main()

代码说明:

  1. connect_to_milvus: 连接到 Milvus 服务。
  2. list_collections: 获取 Milvus 中所有集合的名称。
  3. drop_collection: 删除指定的集合。
  4. drop_all_collections: 遍历所有集合并逐个删除。
  5. main: 主函数,执行连接和删除操作。

注意事项:

数据丢失: 删除集合会永久删除其中的所有数据,请确保你真的想要删除这些数据。
权限: 确保你有足够的权限来删除集合。
连接信息: 确保 hostport 参数正确配置,以便连接到你的 Milvus 服务。

运行代码:

将上述代码保存为一个 Python 文件(例如 delete_collections.py),然后在终端或命令行中运行:

python delete_collections.py

这将连接到 Milvus 并删除所有集合及其数据。

Logo

火山引擎开发者社区是火山引擎打造的AI技术生态平台,聚焦Agent与大模型开发,提供豆包系列模型(图像/视频/视觉)、智能分析与会话工具,并配套评测集、动手实验室及行业案例库。社区通过技术沙龙、挑战赛等活动促进开发者成长,新用户可领50万Tokens权益,助力构建智能应用。

更多推荐