src/worker/index.ts

import 'dotenv/config';
import { PrismaPg } from '@prisma/adapter-pg';
import { PrismaClient } from '@/generated/prisma/client';
import { createRedis } from '@/server/jobs/queue';
import { runWorkerProcess } from '@/server/jobs/runtime';

if (!process.env.DATABASE_URL) throw new Error('请配置 DATABASE_URL');
// 每个进程有自己的连接池；并发保持 2，给进度写入与投递保留连接。
const db = new PrismaClient({
  adapter: new PrismaPg({
    connectionString: process.env.DATABASE_URL,
    max: 5,
    connectionTimeoutMillis: 5000,
  }),
});
const connection = createRedis(true);
runWorkerProcess(db, connection);