json - 通过 NIFI 将带有 jsonb 列的记录插入 Postgres

Question

我在 Postgres 表中有这样的记录：

{"id":1031435,"event_id":"Formula_257","formula_id":257,"ts_start":1583164200084000,"ts_end":1583164484960000,"type":"formula","details":{"6aa0734f-6d6a-4b95-8a2b-2dde346f9df7":{"PowerActiveTriPhase":183836912}},"ack_ts":null,"ack_user":null}

我有 NiFi 流程：

当我尝试将记录插入数据库 (PuDataBaseRecord) 时出现此错误：

PutDatabaseRecord[id=97f19c8c-0171-1000-ffff-ffffda61f966] Failed to process StandardFlowFileRecord[uuid=be8fe243-be1d-45c8-aefa-2bff1c6eb3d0,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1587457195427-149, container=default, section=149], offset=94457, length=242],offset=0,name=be8fe243-be1d-45c8-aefa-2bff1c6eb3d0,size=242] due to Unsupported Types value: 2,002: 

我想这个问题是记录中列之一的 JSONB 格式。然后我从平面文件中删除此列，我可以将记录插入到表中。

有谁知道如何处理它？

谢谢，

标签： jsonpostgresqlapache-nifi

Answer 1

在撰写本文时（NiFi 1.11.4），它仍然是一个未解决的问题（NIFI-5901）。