Всем привет!
Пытаюсь залить любую таблицу в кликхаус через питон.
Возникает следующая ошибка:


Code: 27.
DB::Exception: Cannot parse input: expected '(' before: ')':  at row 0. Stack trace:
 
0. Poco::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int) @ 0x12db83cc in /usr/bin/clickhouse
1. DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int) @ 0xa57a629 in /usr/bin/clickhouse


Ну и так далее. Началось после обновления версий анаконды и питона.
В чем может быть дело ?

ну видимо ваш питон шлет что-то не то в SQL запросе
что такое before: ??

посмотрите system.query_log с текстом запроса полным

А какой клиент используете? не pandahouse случайно?

Before это часть ошибки

А как это узнать ?

ну в импортах обычно написано в py файле

Всем привет.
Если у меня в таблице всего 3 поля
some_array (уникальные миксы массивов)
array_type = могут быть значение только 1, 2, 3, 4
и array_count = могут быть значения от 1 до 100 (int)

На какую колонку лучше делать партицию и в каком порядке лучше делать order?

Господа-знатоки, а подскажите пожалуйста, можно ли сделать такую вещь?
(и если да - то какой максимально "православный" способ это сделать в КХ?)

Есть таблица t, в ней колонка entity_id (Int32), и другая колонка  similar_entities Array(Int32)  все элементы массива - entity_id,
также есть колонка-агрегат agg_col (допустим, среднее значение скорости для entity_id)

можно ли для каждой строки вычислить агрегационную функцию F (допустим avg / max /...) по колонке similar_entities
т.е. для каждой строки данной таблицы с entity_id зайти в массив similar_entities, отфильтровать таблицу t как entity_id in (similar_entities), взять F(agg_col) и записать его в ту же строку?

Там просто
From clickhouse_driver import Client
Import pandas as pd
Import sys
Import re

pip/pip3 list, там указана версия

сколько записей в таблице?
возможно партиции вам и не нужны

выборка в WHERE какие поля указывает?

Click 7.1.2
Clickhouse_driver 0.2.0

Записей - ну допустим 1ккк будет
Во wehere будут использоваться все поля
where hasAll(some_array, [1,2,3]) and  array_type = 1 and array_count > 60
Как пример

я бы делал order by array_type, array_count
партиционирование не делал бы

ORDER BY array_type, array_count

IMHO
PARTITION BY у вас тут максимум по array_type может быть

но это не факт что поможет, если вы сделаете array_type IN ( ... )
то все равно будут партиции сканироваться
и вставка будет более медленная

Понял, спасибо! Так и сделаю

что такое Clik 7.1.2?

повторю
подключитесь к серверу посмотрите содержимое таблицы system.query_log
там будут и ошибка и исходный запрос где там скобки какие то не те указываются

Привет! Запрос на отдельных шардах выполняется крайне быстро (за 3 секунды), а на distributed таблице аж 45 секунд. Куда копнуть чтобы понять в чем такая задержка вызвана? Неужели кх так долго стягивает на главную ноду данные а потом мерджит?

Если по сети много пересылать такое возможно, какая версия кх

21.1.2.15
в сеть ничего не упирается уже смотрел