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 Functions)، غالبًا ما تصطدم بحد المهلة الذي يتراوح بين 10 و 60 ثانية. عند تنفيذ النسخ الاحتياطي للبيانات الكبيرة أو خطوط أنابيب إنتاج الوسائط بالذكاء الاصطناعي متعدد الوسائط، فإن بيئة الخوادم التقليدية توقف التعليمات البرمجية مرارًا وتكرارًا.
تحافظ Vercel Workflows على العمليات مع تقليل استهلاك الموارد إلى الصفر عندما تدخل الدالة في حالة الانتظار. ولتوقع التكاليف، يتم تشغيل نص برمجي لـ TypeScript مباشرة لحساب الإنفاق الشهري مقدماً. بعد تعريف عدد عمليات التنفيذ اليومية، وعدد الخطوات، وقت التنفيذ، وحجم الحمولة ككائنات (objects)، يتم إدخالها في دالة حساب التكلفة. إذا تجاوزت حد 50,000 حدث شهريًا وحد الكتابة بحجم 1 جيجابايت لخطة Hobby، فيجب الاستعداد للترقية إلى 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 مراحل. أولاً، قم بتطبيق غلاف withWorkflow في ملف next.config.ts. ثانياً، اكتب المهام الفردية كدوال غير متزامنة (asynchronous functions) باستخدام توجيه use step بدلاً من عملية العامل (worker) الحالية. ثالثاً، تخلص من بنية تسلسل المهام المعقدة بين الأب والابن واستخدم بيانات التحكم بلغة جافا سكريبت ودالة await sleep داخل استخدام 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 مع الأخطاء المؤقتة والأخطاء الفادحة بشكل منفصل.
لالتقاط الأخطاء داخل الخطوة، قم أولاً بطرح RetryableError عند حدوث خطأ من فئة HTTP 429 أو 500 لتحفيز إعادة المحاولة بناءً على التراجع الأسي (exponential 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 }
});
});
}
`