Привет, подскажите плз, может кто сталкивался, 2й день воюю. Пытаюсь прочитать

Question

Привет, подскажите плз, может кто сталкивался, 2й день воюю. Пытаюсь прочитать

по http большую табличку, сделал http запрос, читаю боди, все хорошо, но ровно через час отваливается, и в body дописывает:

Code: 159, e.displayText() = DB::Exception: Timeout exceeded: elapsed 3600.121469906 seconds, maximum: 3600: \nCode: 159, e.displayText() = DB::Exception: Timeou

читаю примерно на go вот так:

```
req := resty.New().R().
SetContext(ctx).
SetHeaders(config.HTTPAuthHeaders()).
SetQueryParam("database", config.Database).
SetBody([]byte(query))
url := fmt.Sprintf("%v://%v:%v/?database=%v", config.HTTPProtocol(), host, config.HTTPPort, config.Database)
r, err := req.Post(url)
```

#backend #clickhouse #database #devops #programming #russian

0

20.01.2022

9 ответов

24 просмотра

Andrei Tserakhau Автор вопроса

Константин
Ну так у вас тайм аут на 1 час стоит, а потом сесс...

Я пробовал его крутить, он чот не крутится, судя по всему это idle_connection_timeout, но я активно читаю из тела ответа

0

20.01.2022

Константин

socket_timeout параметр сессии

0

20.01.2022

Andrei Tserakhau Автор вопроса

Константин
socket_timeout параметр сессии

Хм, ша попробую поставить его

0

20.01.2022

Andrei Tserakhau Автор вопроса

Константин
socket_timeout параметр сессии

url := fmt.Sprintf("%v://%v:%v/?database=%v&socket_timeout=360000", config.HTTPProtocol(), host, config.HTTPPort, config.Database) вот так его переопределить?

0

20.01.2022

Slach [altinity]

Andrei Tserakhau
url := fmt.Sprintf("%v://%v:%v/?database=%v&socket...

send_timeout и receive_timeout лучше в URL добавлять и со стороны resty SetTimeout сделать

0

20.01.2022

Andrei Tserakhau Автор вопроса

Slach [altinity]
send_timeout и receive_timeout лучше в URL добавля...

не помогло 🙁

0

20.01.2022

Andrei Tserakhau Автор вопроса

Andrei Tserakhau
не помогло 🙁

делал вот так: req := resty.New().SetTimeout(time.Hour * 24).R(). SetContext(ctx). SetHeaders(config.HTTPAuthHeaders()). SetQueryParam("database", config.Database). SetBody([]byte(query)) url := fmt.Sprintf("%v://%v:%v/?database=%v&send_timeout=360000&receive_timeout=360000&idle_connection_timeout=360000", config.HTTPProtocol(), host, config.HTTPPort, config.Database) r, err := req.Post(url) Code: 159, e.displayText() = DB::Exception: Timeout exceeded: elapsed 3600.904620885 seconds, maximum: 3600: \nCode: 159, e.displayText() = DB::Exception: Timeou

0

20.01.2022

Slach [altinity]

Andrei Tserakhau
делал вот так: req := resty.New().SetTimeout(tim...

вам админы ограничили max_execution_time https://clickhouse.com/docs/en/operations/settings/query-complexity/#max-execution-time

0

20.01.2022

Константин · Accepted Answer

Константин

Ну так у вас тайм аут на 1 час стоит, а потом сессию закрывает clickhouse

0

20.01.2022

184 похожих чатов

Привет, подскажите плз, может кто сталкивался, 2й день воюю. Пытаюсь прочитать

9 ответов

Похожие вопросы