ak = os.getenv("TOS_ACCESS_KEY")
sk = os.getenv("TOS_SECRET_KEY")
endpoint = os.getenv("TOS_ENDPOINT")
region = os.getenv("TOS_REGION")
vector_bucket_name = os.getenv("TOS_BUCKET")
client = tos.VectorClient(ak, sk, endpoint, region)
account_id = os.getenv("TOS_ACCOUNT_ID")
print("=== 开始分页列举向量 ===")
print(f"\n--- 第 {page_count} 页 ---")
result = client.list_vectors(
vector_bucket_name=vector_bucket_name,
print(f"请求ID: {result.request_id}")
print(f"状态码: {result.status_code}")
print(f"本页返回向量数量: {len(result.vectors)}")
all_vectors.extend(result.vectors)
for i, vector in enumerate(result.vectors):
print(f"向量 {i+1}: Key={vector.key}")
if vector.data and vector.data.float32:
print(f" Data维度: {len(vector.data.float32)}")
print(f" Metadata: {vector.metadata}")
next_token = result.next_token
while next_token and len(result.vectors) > 0:
print(f"\n--- 第 {page_count} 页 ---")
result = client.list_vectors(
vector_bucket_name=vector_bucket_name,
print(f"请求ID: {result.request_id}")
print(f"本页返回向量数量: {len(result.vectors)}")
all_vectors.extend(result.vectors)
for i, vector in enumerate(result.vectors):
print(f"向量 {i+1}: Key={vector.key}")
next_token = result.next_token
if len(result.vectors) < page_size:
print(f"\n=== 分页列举完成 ===")
print(f"总页数: {page_count}")
print(f"总向量数量: {len(all_vectors)}")
vector_keys = [v.key for v in all_vectors]
unique_keys = set(vector_keys)
print(f"唯一向量Key数量: {len(unique_keys)}")
for i in range(len(all_vectors)):
print(f" Key: {vector.key}")
if vector.data and vector.data.float32:
print(f" Data长度: {len(vector.data.float32)}")
print(f" Data的值: {vector.data.float32}")
print(f" Metadata: {vector.metadata}")
except tos.exceptions.TosClientError as e:
print("fail with client error, message:{}, cause: {}".format(e.message, e.cause))
except tos.exceptions.TosServerError as e:
print("fail with server error, code: {}".format(e.code))
print("error with request id: {}".format(e.request_id))
print("error with message: {}".format(e.message))
print("error with http code: {}".format(e.status_code))
print("error with ec: {}".format(e.ec))
print("error with request url: {}".format(e.request_url))
print("fail with unknown error: {}".format(e))