Upserting Vectors

EXPECTED_DIM = 1536

def validate(vec):
    if len(vec) != EXPECTED_DIM:
        raise ValueError(f"dim {len(vec)} != {EXPECTED_DIM}")
    if not all(isinstance(x, (int, float)) for x in vec):
        raise TypeError("non-numeric value")

index = pc.Index("products")
index.upsert(vectors=[
    {"id": "p1", "values": [0.1, 0.2, ...]},
    {"id": "p2", "values": [0.3, 0.4, ...]},
])

const index = pc.index("products");
await index.upsert([
  { id: "p1", values: [0.1, 0.2] },
  { id: "p2", values: [0.3, 0.4] },
]);

index.upsert(vectors=[{
    "id": "doc1",
    "values": [...],
    "metadata": {
        "source": "wiki",
        "page": 12,
        "tags": ["ml", "vectors"],
        "published": True,
    },
}])

def chunks(lst, size):
    for i in range(0, len(lst), size):
        yield lst[i:i+size]

for batch in chunks(all_vectors, 100):
    index.upsert(vectors=batch)

index.upsert(vectors=batch, namespace="tenant-a")

import time

for attempt in range(5):
    try:
        index.upsert(vectors=batch)
        break
    except Exception as e:
        if attempt == 4: raise
        time.sleep(2 ** attempt)

from concurrent.futures import ThreadPoolExecutor

with ThreadPoolExecutor(max_workers=10) as pool:
    futures = [pool.submit(index.upsert, vectors=b) for b in batches]
    for f in futures: f.result()

await Promise.all(batches.map(b => index.upsert(b)));