2.3.0 • Published 2 years ago
clickhouse-buffer v2.3.0
clickhouse-buffer
Install
yarn add clickhouse-buffer
# or
npm install clickhouse-buffer
How to use
import {ClickhouseBuffer, DEFAULT_DATABASE} from "clickhouse-buffer";
(async () => {
const database = DEFAULT_DATABASE;
const table = 'events';
const directoryPath = await ClickhouseBuffer.prepareDirectoryPath('buffer', database, table, 0o777);
const clickhouseBuffer = new ClickhouseBuffer({
directoryPath,
database,
table
});
await clickhouseBuffer.clickhouseClient.query(`CREATE TABLE IF NOT EXISTS ${database}.${table} (id UInt16) ENGINE = MergeTree() ORDER BY id`);
await clickhouseBuffer.loadFilesToDatabase();
for (let i = 0; i <= 9; i++) {
clickhouseBuffer.push([i]);
}
setTimeout(() => {
for (let i = 10; i <= 19; i++) {
clickhouseBuffer.push([i]);
}
}, 5000)
setTimeout(() => {
clickhouseBuffer.release();
}, 15000);
})();
2.3.0
2 years ago
2.2.3
2 years ago
2.2.2
2 years ago
2.2.1
2 years ago
2.2.0
2 years ago
2.1.0
2 years ago
2.0.1
2 years ago
2.0.0
2 years ago
1.9.10
2 years ago
1.9.9
2 years ago
1.9.8
3 years ago
1.9.6
3 years ago
1.9.5
3 years ago
1.9.4
3 years ago
1.9.1
3 years ago
1.9.0
3 years ago
1.8.0
3 years ago
1.7.0
3 years ago
1.6.0
3 years ago
1.5.0
3 years ago
1.9.3
3 years ago
1.9.2
3 years ago
1.4.0
3 years ago
1.3.0
3 years ago
1.2.0
3 years ago
1.1.0
3 years ago
1.0.0
3 years ago