如何在delta-rs中更新DeltaTable的嵌套对象字段？

问题分析 #

你遇到的报错是因为deltalake Python库的update方法使用的是Delta Lake SQL语法，而非Spark或Python字典写法：

• struct("a": "1", "b": "2")是错误的SQL语法，Delta Lake不支持这种带冒号的写法
• named_struct在deltalake 0.12.0版本中尚未实现，因此无法使用

解决方案 #

1. 更新结构体中的单个字段 #

直接通过.访问嵌套字段，无需替换整个结构体：

dt.update({"my_struct.a": "1", "my_struct.b": "2"})

这种方式可以精准修改结构体内部的指定字段，避免重新构造整个结构体。

2. 替换整个结构体 #

如果需要完全替换my_struct，使用Delta Lake SQL支持的struct函数语法，通过AS指定字段别名：

dt.update({"my_struct": "struct(1 AS a, 2 AS b)"})

完整可运行代码 #

import pandas as pd
from deltalake import write_deltalake, DeltaTable

df = pd.DataFrame.from_records([
     {"name": "Alice", "age": 25, "gender": "Female", "my_struct": {"a": 1, "b": 2}},
     {"name": "Bob", "age": 30, "gender": "Male", "my_struct": {"a": 3, "b": 4}}
])

# 写入Delta表（添加mode避免重复写入报错）
write_deltalake('./db/my_table', df, mode="overwrite")

dt = DeltaTable('./db/my_table')
dt.update({"age": "42"})  # 正常更新根级字段

# 方式1：更新结构体单个字段
dt.update({"my_struct.a": "100", "my_struct.b": "200"})

# 方式2：替换整个结构体（二选一即可）
# dt.update({"my_struct": "struct(100 AS a, 200 AS b)"})

print(dt.to_pandas())

运行后，my_struct字段会被更新为{'a': 100, 'b': 200}，符合预期。

内容的提问来源于stack exchange，提问作者Roar S.