Function upsert

tests/test-key-value-store.py:65–70

(name, txn_id, key: str, value: str)

        raise Exception(f"Failed to abort transaction: {response.text}")

def upsert(name, txn_id, key: str, value: str):
    url = f"{client.base_url}/collections/{name}/transactions/{txn_id}/upsert"
    data = {"vectors": [{"id": key, "bytes": list(value.encode("utf-8"))}]}
    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 upsert vectors: {response.text}")

def bulk_upsert(name, txn_id, items: list[tuple[str, str]]):
    """Upsert multiple key-value pairs in a single request"""