это сообщение об ошибке:
SELECT *
FROM queue2
Received exception from server (version 20.9.3):
Code: 26. DB::Exception: Received from xxxx:xxxx. DB::Exception: Cannot parse JSON string: expected opening quote: (while read the value of key data): (at row 1)
: While executing SourceFromInputStream.
Я создал таблицу kafka для получения данных из темы kafka, и это структура данных:
{
"deviceId": 0,
"data": [
{
"port_id": "2137",
"time":1617103821,
"in":200.5496688741722,
"out":319.4801324503311
}
]
}
это таблица кафки:
CREATE TABLE queue
(
deviceId Int8,
data Nested(
port_id String,
time Int64,
in Float32,
out Float32)
)
ENGINE = Kafka
SETTINGS kafka_broker_list = 'xxx,xxx,xxx',
kafka_topic_list = 'librenms_flow',
kafka_group_name = 'niop-billing-test-group',
kafka_format = 'JSONEachRow',
kafka_num_consumers = 1;
Что мне делать с созданием таблицы кафка и МАТЕРИАЛИЗИРОВАННОГО ВИДА?
Это не JSONEachRow. JSONEachRow - это специальное подмножество JSON. Ваш JSON невозможно проанализировать с помощью JSONEachRow. Вы можете использовать функции JSONAsString Format и JSONExtract.
записи в теме: {"deviceId": 0, "data": [{"port_id": "2137", "time": 1617103821, "in": 200.5496688741722, "out": 319.4801324503311}]}
@vladimir Не могли бы вы мне помочь? Спасибо
Но нет функций JSONExtract: clickhouse.tech/docs/en/interfaces/formats/#jsoneachrow
Вы находитесь на странице форматов, а не функций clickhouse.tech/docs/en/sql-reference/functions/json-functio ns /…
Ошибка предполагает, что некоторая запись в вашей теме не может быть проанализирована, так вы просмотрели все записи в теме?