Written with AI assistance from the source video. The video is the authority.
16:41Vercel
Log in to leave a comment
No posts yet
При управлении SaaS с использованием бессерверных (serverless) функций ограничение тайм-аута в 10–60 секунд гораздо чаще, чем кажется, становится камнем преткновения. При реализации резервного копирования больших объемов данных или конвейеров генерации мультимодального ИИ-контента традиционная серверная среда постоянно прерывает выполнение кода.
Vercel Workflows поддерживает выполнение задач, снижая потребление ресурсов до нуля, когда функция переходит в состояние ожидания. Для прогнозирования затрат мы напрямую запускаем скрипт TypeScript, чтобы заранее рассчитать ежемесячные расходы. Количество ежедневных запусков, количество шагов, время выполнения и размер полезной нагрузки определяются как объекты, а затем передаются в функцию расчета затрат. Если вы превышаете лимит плана Hobby в 50 000 событий в месяц и 1 ГБ записи, вам следует заранее подготовиться к переходу на тариф Pro. При запуске менее 15 000 раз в месяц затраты покрываются за счет базовых кредитов Pro, что снижает расходы по сравнению с поддержкой собственной инфраструктуры Redis.
`typescript
interface WorkflowMetrics {
dailyExecutions: number;
stepsPerExecution: number;
avgStepDurationMs: number;
payloadSizeKb: number;
}
function calculateEstimatedCost(metrics: WorkflowMetrics): { totalEvents: number; estimatedCostUsd: number } {
const totalEvents = metrics.dailyExecutions * metrics.stepsPerExecution * 30;
const freeTierEvents = 50000;
const overageEvents = Math.max(0, totalEvents - freeTierEvents);
const costPerThousand = 0.20;
const estimatedCostUsd = (overageEvents / 1000) * costPerThungk?: number;
return {
totalEvents,
estimatedCostUsd: Number(((overageEvents / 1000) * costPerThousand).toFixed(2))
};
}
`
При использовании BullMQ или AWS SQS приходилось вручную настраивать создание очередей, отправку и получение задач, а также управление соединениями Redis. Из-за этого код раздувается и становится избыточным. SDK Vercel Workflows устраняет этот инфраструктурный код с помощью директив на уровне кода.
Миграция выполняется в 3 этапа. Во-первых, оберните файл next.config.ts с помощью withWorkflow. Во-вторых, вместо традиционных процессов воркеров напишите отдельные задачи как асинхронные функции, используя директиву use step. В-третьих, откажитесь от сложной цепочки заданий Parent-Child Job и используйте операторы управления JavaScript и функцию await sleep внутри use workflow. По мере исчезновения кода внешнего подключения к Redis объем памяти приложения уменьшается, а время перехода ускоряется.
`typescript
import { workflow } from "@vercel/workflows";
export const { POST } = workflow(async (context) => {
const userId = context.request.payload.userId;
const data = await context.run("fetch-user-data", async () => {
const res = await fetch(https://api.example.com/users/${userId});
return res.json();
});
await context.sleep("wait-for-processing", "10m");
await context.run("finalize-task", async () => {
await db.users.update({ where: { id: userId }, data: { status: "processed" } });
});
});
`
Чтобы предотвратить потерю данных при возникновении недетерминированных сбоев, необходимо сначала разделить типы ошибок. Vercel Workflows разделяет временные и критические ошибки.
Чтобы перехватить ошибку внутри шага, при возникновении ошибок HTTP 429 или 500 сначала выдается RetryableError, что инициирует повторную попытку на основе экспоненциальной задержки (backoff). Кроме того, внутри шага, изменяющего базу данных, добавляется логика проверки уникального ключа, чтобы предотвратить накопление дубликатов данных при повторных попытках. Наконец, подключите Vercel Log Drains к Sentry для потоковой передачи структурированных JSON-логов в реальном времени. Применение этого шаблона позволяет восстанавливать состояние с точки останова даже в исключительных ситуациях, избавляя от необходимости восстанавливать данные вручную.
`typescript
import { RetryableError } from "@vercel/workflows";
export async function processPaymentStep(context: any, paymentData: any) {
return await context.run("charge-payment", async () => {
const exists = await db.transactions.findUnique({
where: { idempotencyKey: paymentData.key }
});
if (exists) {
return exists;
}
const response = await paymentGateway.charge(paymentData);
if (response.status === 429 || response.status >= 500) {
throw new RetryableError("Payment gateway overloaded, retrying...");
}
return await db.transactions.create({
data: { idempotencyKey: paymentData.key, amount: response.amount }
});
});
}
`