kafka ksql выдержка json fleld буквальный символ доллара

Question

У меня есть поток данных, поступающий из разъема mongo CDC, но проблема в том, что ключ потока находится в форме строки JSON.

например, {"id":"{ \"$oid\" : \"5bbb0c70cd0b9c06cf06c9c1\"}"}

Я знаю, что могу использовать метод extractjsonfield для извлечения данных с использованием jsonpath, однако я не могу понять, как извлечь буквальный символ доллара, который я пробовал: $.id.$oid $.id[\$oid] $.id.*

каждый раз, когда я получаю нулевой ответ, есть идеи?

Answer 1

Я полагаю, что ваша проблема связана с проблемой # 1403 .
Вы можете использовать [\\" field_name \\"] для ссылки на столбец.Например,

SELECT EXTRACTJSONFIELD(test,'$[\\"$oid\\"]') FROM testing;