bisheng
bisheng copied to clipboard
毕昇自定义的 milvus.py 里关于 ConnectionNotExistException 的处理逻辑是不是无效?
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这个异常么?
@zgqgit