GridDB Python：为现有容器添加列后出现TypeError问题求助

问题原因 #

GridDB Python客户端会缓存容器的schema信息，当你通过put_container更新服务端的容器schema后，客户端本地的缓存并不会自动刷新。后续查询时，客户端仍按照旧的schema结构解析包含新列的数据行，导致字段数量不匹配，触发TypeError或IndexError。同时，同一个会话内复用的容器实例会持有旧的schema定义，无法识别新增列。

解决方案 #

针对该问题，有几种直接有效的处理方式：

• 重新建立客户端连接：更新schema后关闭当前GridStore实例，重新获取连接，确保客户端加载最新的容器元数据。
• 重新获取容器实例：更新schema后，不要复用之前的容器对象，调用get_container重新获取容器，以获取最新的schema信息。
• 避免同会话连续更新schema：尽量不在同一个连接会话内连续创建不同版本的ContainerInfo并执行put_container，减少缓存冲突的概率。

修正后的代码示例 #

import griddb_python as griddb

factory = griddb.StoreFactory.get_instance()

# 初始创建容器
gridstore = factory.get_store(host="192.168.10.1", port=10001, cluster_name="myCluster", user="admin", password="admin")
info_v1 = griddb.ContainerInfo("data_coll", [["id", griddb.Type.INTEGER], ["value", griddb.Type.DOUBLE]], griddb.ContainerType.COLLECTION, True)
gridstore.put_container(info_v1)

# 关闭旧连接，重新建立连接以刷新元数据缓存
gridstore.close()
gridstore = factory.get_store(host="192.168.10.1", port=10001, cluster_name="myCluster", user="admin", password="admin")

# 更新容器schema
info_v2 = griddb.ContainerInfo("data_coll", [["id", griddb.Type.INTEGER], ["value", griddb.Type.DOUBLE], ["status", griddb.Type.STRING]], griddb.ContainerType.COLLECTION, True)
gridstore.put_container(info_v2)

# 获取最新的容器实例
col = gridstore.get_container("data_coll")
col.put([1, 10.5, "active"])

# 执行查询并遍历结果
query = col.query("select *")
rs = query.fetch()
while rs.has_next():
    data = rs.next()
    print(data)

额外注意事项 #

• 更新schema时，必须保证ContainerInfo中的容器名称、类型与原容器完全一致，否则会创建新容器而非更新原有容器。
• 对于更新前已存在的数据行，新增列会被自动填充对应类型的默认值（如字符串类型为None，数值类型为0），查询时可正常解析。

内容的提问来源于stack exchange，提问作者Farwa Waheed