使用GridDB Python客户端插入数据后未持久化的问题排查

我使用GridDB Python客户端向容器插入数据，代码执行无报错，但查询容器时找不到插入的数据。代码如下：

import griddb_python as griddb

factory = griddb.StoreFactory.get_instance()

try:
    # Connect to the GridDB store
    store = factory.get_store(
        notification_member="123.0.0.1",
        notification_port=31999,
        cluster_name="myCluster",
        username="admin",
        password="admin"
    )

    # Retrieve or create the container
    container = store.get_container("personContainer")
    if container is None:
        container_info = griddb.ContainerInfo(
            "personContainer",
            [
                griddb.ColumnInfo("id", griddb.GS_TYPE_INTEGER),
                griddb.ColumnInfo("name", griddb.GS_TYPE_STRING),
                griddb.ColumnInfo("age", griddb.GS_TYPE_INTEGER)
            ],
            griddb.CONTAINER_COLLECTION, True
        )
        container = store.put_container(container_info)

    # Insert data
    row = [1, "John Doe", 30]
    container.put(row)

except griddb.GSException as e:
    for i in range(e.get_error_stack_size()):
        print(f"[{i}] Error code: {e.get_error_code(i)}")
        print(f"Error message: {e.get_message(i)}")

已确认GridDB服务器运行正常、容器schema正确且存在，但插入的数据始终无法检索到。

核心原因：事务未提交 #

GridDB Python客户端默认采用事务式操作，所有数据写入操作（如put）会先暂存到本地事务缓存中，只有显式提交事务后，数据才会持久化到集群并可被外部查询到。你的代码中缺少事务提交步骤，导致数据未真正写入服务器。

解决步骤 #

1. 显式提交事务 #

在数据插入完成后，调用store.commit()提交事务，确保数据持久化：

# Insert data
row = [1, "John Doe", 30]
container.put(row)

# 提交事务
store.commit()

2. 可选：设置自动提交（简化操作） #

如果希望每次数据操作自动提交，可以在获取Store实例时添加autocommit=True配置：

store = factory.get_store(
    notification_member="123.0.0.1",
    notification_port=31999,
    cluster_name="myCluster",
    username="admin",
    password="admin",
    autocommit=True  # 开启自动提交
)

开启自动提交后，每次put、update等操作会立即提交事务，无需手动调用commit()。

3. 验证数据写入（可选） #

提交事务后可添加查询代码，验证数据是否成功写入：

# 提交事务后查询数据
query = container.query("SELECT * WHERE id = 1")
rs = query.fetch()
while rs.has_next():
    print(rs.next())

其他排查点 #

• 确认集群连接信息正确：notification_member、cluster_name需与服务器配置完全匹配，避免连接到错误集群。
• 检查分区容器配置：代码中创建容器时设置了is_partition=True，GridDB会自动处理分区路由，若出现查询异常可确认服务器分区配置是否正常。

内容的提问来源于stack exchange，提问作者Josh Adams