如何使用Python指定RocksDB列族，解决列族未打开错误并遍历数据

报错原因 #

触发该错误的核心原因是：RocksDB要求打开实例时必须显式声明所有已存在的列族，你当前仅手动指定了col11个列族，但目标库实际存在col0到col11共12个列族，未指定的列族不会被自动加载，因此触发参数校验错误。

正确配置步骤 #

• 首先读取目标库中所有已存在的列族列表，避免手动硬编码遗漏
• 为所有列族配置参数后，完整传入数据库打开方法
• 遍历所有列族的迭代器即可读取全量数据

示例代码 #

import rocksdb

# 替换为你的RocksDB目录路径
db_path = "<your-db-path>"

# 读取所有现存列族名称
exist_cf_names = rocksdb.list_column_families(db_path, rocksdb.Options())
# 为每一个列族生成配置，可根据需求单独调整特定列族的参数
column_families = {
    cf_name: rocksdb.ColumnFamilyOptions() 
    for cf_name in exist_cf_names
}

# 传入全量列族打开数据库
db = rocksdb.DB(
    db_path,
    rocksdb.Options(create_if_missing=False),
    column_families=column_families
)

# 遍历所有列族的所有行数据
for cf_handle in db.column_families.values():
    cf_name = cf_handle.name.decode("utf-8")
    print(f"===== 列族 {cf_name} 数据 =====")
    # 创建当前列族的迭代器
    cf_iter = db.iteritems(cf_handle)
    cf_iter.seek_to_first()
    for key, value in cf_iter:
        print(f"键: {key}, 值: {value}")

注意事项 #

• 若不同列族需要定制化参数（如压缩策略、缓存大小等），可单独为对应列族的ColumnFamilyOptions赋值，无需统一使用默认配置
• 遍历数据时也可根据业务需求只读取指定列族的内容，只要打开时传入全部列族即可，不强制遍历所有列族

内容的提问来源于stack exchange，提问作者Aviral Srivastava