zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add retry if timeout error for clickhouse

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-07-18 21:16:07 +02:00
parent 7a0190c186
commit 9ee8626f96
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/db/src/buffers/buffer.ts
View File

@@ -29,7 +29,7 @@ const getError = (e: unknown) => {
'Name: ' + e.name, 'Name: ' + e.name,
'Message: ' + e.message, 'Message: ' + e.message,
'Stack: ' + e.stack, 'Stack: ' + e.stack,
'Cause: ' + e.cause, 'Cause: ' + (e.cause ? String(e.cause) : ''),
].join('\n'); ].join('\n');
} }
return 'Unknown error'; return 'Unknown error';

10
packages/db/src/clickhouse-client.ts
View File

@@ -7,9 +7,10 @@ export const originalCh = createClient({
password: process.env.CLICKHOUSE_PASSWORD, password: process.env.CLICKHOUSE_PASSWORD,
database: process.env.CLICKHOUSE_DB, database: process.env.CLICKHOUSE_DB,
max_open_connections: 10, max_open_connections: 10,
request_timeout: 10000,
keep_alive: { keep_alive: {
enabled: true, enabled: true,
idle_socket_ttl: 5000, idle_socket_ttl: 8000,
}, },
compression: { compression: {
request: true, request: true,
@@ -29,10 +30,11 @@ export const ch = new Proxy(originalCh, {
} catch (error: unknown) { } catch (error: unknown) {
if ( if (
error instanceof Error && error instanceof Error &&
error.message.includes('socket hang up') (error.message.includes('socket hang up') ||
error.message.includes('Timeout error'))
) { ) {
console.error( console.info(
`Caught socket hang up error on ${property.toString()}, retrying once.` `Caught ${error.message} error on ${property.toString()}, retrying once.`
); );
await new Promise((resolve) => setTimeout(resolve, 500)); await new Promise((resolve) => setTimeout(resolve, 500));
try { try {