1. <?php
  3. /**
  4. * Batch Operations with Graceful Failure Handling
  5. *
  6. * This function processes a list of entries in batches, handling errors gracefully
  7. * and logging them.
  8. *
  9. * @param array $entries An array of entries to process. Each entry should be an associative array.
  10. * @param int $batch_size The number of entries to process in each batch.
  11. * @param callable $operation A callable (function) that takes an entry as input and performs the operation.
  12. * @param callable|null $error_handler An optional callable to handle errors. If null, errors are logged.
  13. * @return array An array of results, where each result corresponds to an entry. Returns an array of errors if something goes wrong.
  14. */
  15. function batch_operations(array $entries, int $batch_size, callable $operation, ?callable $error_handler = null): array
  16. {
  17. $results = [];
  18. $errors = [];
  20. if (empty($entries)) {
  21. return $results; // Return empty array if no entries
  22. }
  24. for ($i = 0; $i < count($entries); $i += $batch_size) {
  25. $batch = array_slice($entries, $i, $batch_size);
  27. foreach ($batch as $entry) {
  28. try {
  29. $result = $operation($entry);
  30. $results[] = $result; // Store the result
  31. } catch (\Exception $e) {
  32. $error_message = "Error processing entry: " . json_encode($entry) . "\n" . $e->getMessage();
  34. if ($error_handler) {
  35. $error_handler($error_message, $entry); // Use custom error handler
  36. } else {
  37. $errors[] = ['entry' => $entry, 'error' => $error_message]; // Log error
  38. }
  39. }
  40. }
  41. }
  43. if (!empty($errors)) {
  44. return $errors; // Return errors if any
  45. }
  47. return $results;
  48. }
  50. // Example Usage (demonstration)
  51. /*
  52. // Sample operation (replace with your actual operation)
  53. function process_entry(array $entry): string
  54. {
  55. // Simulate an error sometimes
  56. if (rand(0, 10) < 2) {
  57. throw new \Exception("Simulated error!");
  58. }
  59. return "Processed: " . $entry['id'];
  60. }
  62. // Example error handler
  63. function my_error_handler($message, $entry) {
  64. error_log("Custom Error: " . $message);
  65. }
  67. $entries = [
  68. ['id' => 1, 'data' => 'value1'],
  69. ['id' => 2, 'data' => 'value2'],
  70. ['id' => 3, 'data' => 'value3'],
  71. ['id' => 4, 'data' => 'value4'],
  72. ['id' => 5, 'data' => 'value5'],
  73. ];
  75. $batch_size = 2;
  77. $results = batch_operations($entries, $batch_size, 'process_entry', [$my_error_handler]);
  79. if (empty($results)) {
  80. echo "All entries processed successfully.\n";
  81. } else {
  82. echo "Errors occurred during processing:\n";
  83. print_r($results);
  84. }
  85. */
  87. ?>

Add your comment