Written with AI assistance from the source video. The video is the authority.
16:41Vercel
Log in to leave a comment
No posts yet
Ao operar um SaaS com funções serverless, o limite de tempo limite de 10 a 60 segundos frequentemente se torna um obstáculo. Ao implementar backups de dados de grande escala ou pipelines de geração de mídia de IA multimodal, o ambiente serverless existente acaba interrompendo o código repetidamente.
Vercel Workflows mantém as operações ativas enquanto reduz o consumo de recursos a zero quando a função entra em estado de espera. Para prever custos, execute um script TypeScript diretamente para calcular os gastos mensais antecipadamente. Defina o número diário de execuções, o número de etapas, o tempo de execução e o tamanho do payload como objetos e insira-os na função de cálculo de custos. Se você exceder o limite mensal de 50.000 eventos e 1 GB de gravação do plano Hobby, precisará se preparar para a atualização para o Pro com antecedência. Se você executar menos de 15.000 vezes por mês, poderá absorvê-lo dentro do crédito básico do Pro, reduzindo os custos em comparação com a manutenção de uma infraestrutura Redis auto-hospedada.
`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))
};
}
`
Ao usar BullMQ ou AWS SQS, a criação de filas, publicação de trabalhos, recebimento e gerenciamento de conexões Redis eram todos codificados manualmente. Esse processo infla o código desnecessariamente. O SDK do Vercel Workflows elimina esse código de infraestrutura com diretrizes em nível de código.
A migração é concluída em 3 etapas. Primeiro, envolva com o wrapper withWorkflow no arquivo next.config.ts. Segundo, em vez do processo de trabalhador existente, use a diretriz use step para escrever tarefas individuais como funções assíncronas. Terceiro, descarte a estrutura complexa de encadeamento de trabalhos Pai-Filho e use instruções de controle JavaScript e a função await sleep dentro de use workflow. À medida que o código de conexão Redis externo desaparece, a pegada de memória do aplicativo diminui e o tempo de transição acelera.
`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" } });
});
});
`
Para evitar a perda de dados quando ocorre uma falha não determinística, a natureza do erro deve ser separada primeiro. O Vercel Workflows lida com erros temporários e fatais separadamente.
Para capturar erros dentro de uma etapa, primeiro lance um RetryableError quando ocorrer um erro da série HTTP 429 ou 500 para induzir tentativas baseadas em backoff exponencial. Além disso, inclua a lógica de verificação de chave exclusiva dentro da etapa que modifica o banco de dados para evitar o acúmulo de dados duplicados durante as tentativas. Por fim, conecte o Vercel Log Drains ao Sentry para transmitir logs JSON estruturados em tempo real. Ao aplicar esse padrão, o estado é restaurado a partir do ponto de interrupção mesmo em situações excepcionais, eliminando a necessidade de recuperar dados manualmente.
`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 }
});
});
}
`