вставить запись со столбцом jsonb в Postgres через NIFI - PullRequest
0 голосов
/ 21 апреля 2020

У меня есть такая запись в таблице 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: enter image description here

Когда я пытаюсь вставить запись в базу данных (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 одного из столбцов в записи. Затем я удаляю этот столбец из плоского файла и могу вставить запись в таблицу.

Кто-нибудь знает, как с этим справиться?

Спасибо,

1 Ответ

1 голос
/ 21 апреля 2020

На момент написания этой статьи (NiFi 1.11.4) этот вопрос все еще оставался открытым ( NIFI-5901 ).

...