diff --git a/packages/db/src/buffers/bot-buffer-psql.ts b/packages/db/src/buffers/bot-buffer-psql.ts index 1449528b..db0d9416 100644 --- a/packages/db/src/buffers/bot-buffer-psql.ts +++ b/packages/db/src/buffers/bot-buffer-psql.ts @@ -1,7 +1,4 @@ -import { generateSecureId } from '@openpanel/common/server/id'; -import { type ILogger, createLogger } from '@openpanel/logger'; -import { getRedisCache, runEvery } from '@openpanel/redis'; -import { Prisma } from '@prisma/client'; +import { runEvery } from '@openpanel/redis'; import { TABLE_NAMES, ch } from '../clickhouse-client'; import { db } from '../prisma-client'; diff --git a/packages/db/src/buffers/event-buffer-psql.ts b/packages/db/src/buffers/event-buffer-psql.ts index 5d48953d..39e967e4 100644 --- a/packages/db/src/buffers/event-buffer-psql.ts +++ b/packages/db/src/buffers/event-buffer-psql.ts @@ -1,6 +1,4 @@ import { setSuperJson } from '@openpanel/common'; -import { generateSecureId } from '@openpanel/common/server/id'; -import { type ILogger as Logger, createLogger } from '@openpanel/logger'; import { getRedisCache, getRedisPub, runEvery } from '@openpanel/redis'; import { Prisma } from '@prisma/client'; import { ch } from '../clickhouse-client'; @@ -198,7 +196,8 @@ export class EventBuffer extends BaseBuffer { timer.markAsProcessed = performance.now() - now; this.logger.info('Processed events', { - count: toInsert.length, + inserted: toInsert.length, + processed: eventsToProcess.length, timer, }); } diff --git a/packages/db/src/buffers/profile-buffer-psql.ts b/packages/db/src/buffers/profile-buffer-psql.ts index c56483da..7233c3c7 100644 --- a/packages/db/src/buffers/profile-buffer-psql.ts +++ b/packages/db/src/buffers/profile-buffer-psql.ts @@ -1,7 +1,5 @@ import { createHash } from 'node:crypto'; -import { generateSecureId } from '@openpanel/common/server/id'; -import { type ILogger as Logger, createLogger } from '@openpanel/logger'; -import { getRedisCache, runEvery } from '@openpanel/redis'; +import { runEvery } from '@openpanel/redis'; import { mergeDeepRight } from 'ramda'; import { TABLE_NAMES, ch, chQuery } from '../clickhouse-client';