milvus数据库怎么写

综合交流
1

使用langchain_community对Milvus向量数据库创建collection时，为什么连接到的都是default数据库，如果使用其他的数据库，代码该怎么写？

from langchain_community.vectorstores import Milvus

vector_store = Milvus(
        embedding_function=embedding_model,
        collection_name=milvus_config["collection_name"],
        consistency_level="Bounded",
        connection_args={"host": milvus_config["host"], "port": milvus_config["port"]},
    )
2

你这段配置只指定了实例的 host / port，没有指定数据库。数据库名和 collection_name 是两层概念，不能把数据库名写进 collection 名称来替代选择数据库。

可先在连接参数中明确加入 db_name，保持你当前用的导入路径不变：

vector_store = Milvus(
    embedding_function=embedding_model,
    collection_name=milvus_config["collection_name"],
    consistency_level="Bounded",
    connection_args={
        "host": milvus_config["host"],
        "port": milvus_config["port"],
        "db_name": "your_database",  # 已存在且当前账号有权访问的数据库
    },
)

langchain_community 的具体行为还取决于版本：我核对的官方源码会把连接参数传给 pymilvus.connections.connect，但已有连接复用分支按地址和用户匹配，未比较数据库名。因此，如果你在同一进程先连过 default，再新增 db_name，要留意是否复用了旧连接；可以在独立测试进程中先做验证，避免直接断开生产共享连接。

当前独立集成 langchain_milvus 的官方示例也在 connection_args 中使用 db_name；这不意味着必须立即迁移包。旧版实现参考官方源码。

验证时先用同一个数据库配置查看已有 collection，确认库与账号权限，再考虑写入；不要为测试设置 drop_old=True 或执行删除示例。

这里没有你的 Milvus 服务端，代码尚未做联网验证。请补充 Milvus 服务端、pymilvus、langchain-community 版本，以及是否在同一进程连接多个库；若加参数后仍落到 default，再对照实际连接复用情况定位。