Function bulk_upsert

tests/test-key-value-store.py:72–78

Upsert multiple key-value pairs in a single request

(name, txn_id, items: list[tuple[str, str]])

        raise Exception(f"Failed to upsert vectors: {response.text}")

def bulk_upsert(name, txn_id, items: list[tuple[str, str]]):
    """Upsert multiple key-value pairs in a single request"""
    url = f"{client.base_url}/collections/{name}/transactions/{txn_id}/upsert"
    data = {"vectors": [{"id": k, "bytes": list(v.encode("utf-8"))} for k, v in items]}
    response = requests.post(url, headers=client._get_headers(), data=json.dumps(data), verify=client.verify_ssl)
    if response.status_code not in [200, 204]:
        raise Exception(f"Failed to bulk upsert: {response.text}")

def lookup(name, key):
    url = f"{client.base_url}/collections/{name}/search/key-value"