我们需要将postgres中的数据插入clickhouse。postgres中的一个字段具有json类型。 在clickhouse中,此字段的类型为空(字符串)。 对于插入数据,我们使用气流ClickHouse插件:
data = postgress_hook.get_records(query)
clickhouse_hook.run(
sql="INSERT INTO "+ self.clickhouse_tgt_table +" values",
parameters=data
)
但我们在插入过程中出错:
'dict' object has no attribute 'encode'
我们应该使用什么样的clickhouse类型来存储json数据
此消息不是来自CH服务器,而是来自python驱动程序
相关问题 更多 >
编程相关推荐