【发布时间】:2021-02-19 01:59:44
【问题描述】:
我们需要将数据从 postgres 插入到 clickhouse。 postgres 中的字段之一具有 json 类型。 在 clickhouse 中,此字段具有 Nullable(String) 类型。 对于插入数据,我们使用 Airflow 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 数据?
【问题讨论】:
-
您能否提供错误的详细描述(使用调用堆栈)?您确定 query 的类型为 str 而不是 dict?
标签: python postgresql clickhouse