fix: outdated import of src/importSnapshots.ts
This commit is contained in:
parent
abb75d2d3d
commit
ac86ab6f75
@ -29,13 +29,17 @@
|
||||
<excludeFolder url="file://$MODULE_DIR$/data" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/redis" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/ml" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/src" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/crawler/.cache" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/solid/.vinxi" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/.jj" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/.jj/repo" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/.jj/working_copy" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/solid/.output" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/.turbo" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/cf-worker/.turbo" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/core/.turbo" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/crawler/.turbo" />
|
||||
<excludeFolder url="file://$MODULE_DIR$/packages/temp_frontend/.turbo" />
|
||||
</content>
|
||||
<orderEntry type="inheritedJdk" />
|
||||
<orderEntry type="sourceFolder" forTests="false" />
|
||||
|
||||
@ -6,6 +6,7 @@
|
||||
<file url="file://$PROJECT_DIR$/queries/schedule_count.sql" value="0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef" />
|
||||
<file url="file://$PROJECT_DIR$/queries/schedule_window.sql" value="0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef" />
|
||||
<file url="file://$PROJECT_DIR$/queries/snapshots_count.sql" value="0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef" />
|
||||
<file url="file://$PROJECT_DIR$/src/importSnapshots.ts" value="0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef" />
|
||||
<file url="file://$APPLICATION_CONFIG_DIR$/consoles/db/0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef/console_4.sql" value="0d2dd3d3-bd27-4e5f-b0fa-ff14fb2a6bef" />
|
||||
</component>
|
||||
</project>
|
||||
@ -1,8 +1,8 @@
|
||||
import { sql } from "@core/index";
|
||||
import fs from "node:fs/promises";
|
||||
import path from "node:path";
|
||||
import { sql } from "@core/db/dbNew";
|
||||
import logger from "@core/log";
|
||||
import arg from "arg";
|
||||
import fs from "fs/promises";
|
||||
import path from "path";
|
||||
|
||||
const quit = (reason?: string) => {
|
||||
reason && logger.error(reason);
|
||||
@ -64,7 +64,8 @@ if (!aid) {
|
||||
const pg = sql;
|
||||
|
||||
async function importData() {
|
||||
const data = await fetchData(aid!);
|
||||
if (!aid) return;
|
||||
const data = await fetchData(aid);
|
||||
const length = data.length;
|
||||
logger.log(`Found ${length} snapshots for aid ${aid}`);
|
||||
let i = 0;
|
||||
@ -75,7 +76,7 @@ async function importData() {
|
||||
await pg`
|
||||
INSERT INTO video_snapshot (aid, created_at, views, danmakus, replies, favorites, coins, shares, likes)
|
||||
VALUES (${record.aid}, ${timeString}, ${record.view}, ${record.danmaku}, ${record.reply}, ${record.favorite}, ${record.coin}, ${record.share}, ${record.like})
|
||||
`;
|
||||
`;
|
||||
} catch (e) {
|
||||
logger.error(e as Error);
|
||||
logger.warn(
|
||||
|
||||
Loading…
Reference in New Issue
Block a user