@chkit/plugin-ingest
v0.2.0-beta.8
Published
Scheduled pull ingestion into ClickHouse with journaled checkpoints for chkit
Downloads
210
Maintainers
Readme
@chkit/plugin-ingest
Write TypeScript readers to load application API data into ClickHouse with chkit. Use an external scheduler for repeated runs.
The executor records progress after writes succeed. A retry can reread rows from the last committed checkpoint.
import { defineConfig } from '@chkit/core'
import { ingest } from '@chkit/plugin-ingest'
export default defineConfig({
entry: './src/chkit.ts',
plugins: [ingest()],
clickhouse: { url: process.env.CLICKHOUSE_URL ?? '' },
})chkit ingest run --tag schedule:1hDocumentation: https://chkit.obsessiondb.com/api-sync/
For raw storage, typed rows, and where to map fields, see Destinations and transformations.
Install the source-authoring skill for a coding agent:
npx skills add obsessiondb/chkit --skill chkit-ingestion