Laravel Chores لإجراء عمليات البيانات الطويلة مع الاستئناف بعد التوقف

عمليات البيانات الكبيرة لا تفشل دائماً بسبب الاستعلام نفسه؛ أحياناً يكفي deploy بعد ساعات من التشغيل كي تصبح معرفة السجلات التي عولجت بالفعل مشكلة بحد ذاتها. حزمة Laravel Chores تقدّم طريقة منظمة لتشغيل أعمال لمرة واحدة أو دورية، مثل backfills وعمليات التنظيف والحذف، عبر دفعات تحتفظ بنقطة تقدّم قابلة للاستئناف.

الحزمة، التي طوّرها Amr Lotfy Saleh، تكتب آخر ID تمت معالجته في جدول chore_runs بعد كل batch. لذلك، إذا انقطعت العملية بسبب crash أو إيقاف يدوي عبر Ctrl+C أو إعادة تشغيل أثناء deploy، فإن التشغيل التالي يستأنف من آخر checkpoint بدلاً من بدء المهمة من الصفر. لكن هذا الضمان يكون على مستوى الدفعة، لا السجل المفرد؛ فقد تُفحص سجلات الدفعة التي كانت قيد التنفيذ مرة أخرى بعد الاستئناف. لهذا يُنصح بأن تكون دالة process() idempotent قدر الإمكان.

تعتمد Laravel Chores على keyset pagination باستخدام المفتاح الأساسي بدلاً من offset. هذا مهم عند تعديل السجلات أثناء المرور عليها، لأن pagination المعتمدة على offset قد تؤدي إلى تخطي صفوف أو تحريكها خارج الدفعة الحالية. وتحتاج المجموعة إلى primary key قابل للترتيب، مثل auto-increment أو ULID.

كل Chore عبارة عن class يحدد دالتين أساسيتين: collection() لإرجاع query السجلات المستهدفة، وprocess() لمعالجة سجل واحد. يمكن إنشاء الهيكل المبدئي بالأمر:

php artisan make:chore

في مثال تطبيع أرقام الهواتف، يمكن أن تختار collection() المستخدمين الذين لديهم رقم هاتف لا يبدأ بـ +، ثم تحوّل process() الرقم إلى صيغة E.164. إذا لم يُحدَّد حجم الدفعة في الـ class، تستخدم الحزمة القيمة الافتراضية في ملف الإعدادات، وهي 500.

لتشغيل مهمة، يُستخدم الأمر php artisan chore:run NormalizePhoneNumbers، مع عرض تقدّم مباشر في الطرفية. كما توفر الحزمة أوامر لعرض المهام وسجل تشغيلها، وإيقاف مهمة عند نهاية الدفعة التالية، وفحص السجلات الفاشلة ثم إعادة محاولة معالجتها. إذا تسبب سجل واحد في exception، تسجل الحزمة السجل والخطأ في جدول failures وتتجاوز السجل لتواصل بقية التشغيل.

هذا الفصل بين التشغيل الرئيسي وإعادة المحاولة مفيد في المهام الطويلة: أخطاء عدد محدود من السجلات لا تعني إهدار ساعات من المعالجة، ويمكن إعادة محاولة السجلات التي فشلت بعد إصلاح سبب المشكلة بدلاً من إعادة المهمة كاملة.

لا تحتاج Laravel Chores إلى Redis أو Queue workers أو خدمات خارجية، إذ تحفظ حالتها في قاعدة البيانات. وتعمل حالياً في foreground مع worker واحد لكل chore. أما queued execution والـ parallel workers فمذكوران ضمن خارطة الطريق. وللمهام المتكررة، يمكن تشغيل الأمر من Laravel task scheduler، مثل مهمة شهرية لحذف السجلات المنتهية.

توفر الحزمة أيضاً مخرجات JSON مناسبة لـ CI، مع exit code بقيمة 0 عند نجاح التشغيل دون أخطاء، و1 عند اكتماله مع وجود سجلات فاشلة، و2 عند حدوث خطأ fatal.

تتطلب Laravel Chores كلاً من PHP 8.2 أو أحدث وLaravel 12 أو 13، وتدعم MySQL وPostgreSQL وSQLite. يبدأ التثبيت عبر:

composer require amrlotfy/laravel-chores

ثم نشر migrations وتشغيلها عبر php artisan vendor:publish --tag=chores-migrations وphp artisan migrate. ويمكن من ملف الإعدادات تعديل مسار classes وحجم الدفعة الافتراضي وأسماء الجداول وفاصل زمني بين الدفعات لتخفيف الحمل على قاعدة بيانات مشغولة.