如何在 Laravel 中使用 chunk() 进行进度和失败更新？

Question

Laravel Eloquent 模型称为 ProductModel，它引用包含大量行（即 500,000）的表。每行包含一个product_id，它调用函数isValid()，该函数要么继续循环，要么中断循环。

https://laravel.com/docs/9.x/eloquent#chunking- results

我创建的用于说明问题的示例：（更新 16/03/22）

$log = array();
$log[] = ['Checking products...'];

$count = 0;
$chunks = 5000;
$total = ProductModel::count();

ProductModel::chunk($chunks, function ($products) uses (&$count, $log, $total) {
    foreach ($products as $row) {
        $this->isValid($row->product_id);
        $count++;
    }
    $log[] = '[Success] Completed '. $count .' of '. $total .' records';
});

然后，循环的每个记录都存储在数组中$log。

[Success] Completed 5,000 of 20,000 records
[Success] Completed 10,000 of 20,000 records
[Success] Completed 15,000 of 20,000 records
[Success] Completed 20,000 of 20,000 records

如果从 $this->isValid() 引发 Exception，则数组 $log 应包含类似于以下内容的内容：

Checking products...
[Success] Completed 5,000 of 20,000 records
[Failed] Completed 7,402 of 20,000 records