bisheng icon indicating copy to clipboard operation
bisheng copied to clipboard

毕昇自定义的 milvus.py 里关于 ConnectionNotExistException 的处理逻辑是不是无效?

Open izualzhy opened this issue 4 months ago • 1 comments

    def add_texts(...)
        # 省略不重要代码
        try:
            res = self.col.insert(insert_list, timeout=timeout, **kwargs)
            pks.extend(res.primary_keys)
        except ConnectionNotExistException as e:
            logger.warning(f'retrying connection to milvus {e}')
            # reconnect to milvus
            self._create_connection_alias(self.connection_args, self.alias)

            # insert data
            res = self.col.insert(insert_list, timeout=timeout, **kwargs)
            pks.extend(res.primary_keys)

当前的 alias 是在_create_connection_alias返回的,首次创建为一个随机值alias,后续则根据 address user 复用,复用的话返回之前的随机值alias。 上述代码里,如果连接异常导致ConnectionNotExistException报错,通过当前 alias 拿到的还是原来的连接,能解决ConnectionNotExistException这个异常么?

izualzhy avatar Aug 08 '25 10:08 izualzhy

@zgqgit

sara2398 avatar Sep 05 '25 03:09 sara2398