1. <?php
  3. /**
  4. * Imports data from a JSON file with retry logic.
  5. *
  6. * @param string $jsonFilePath The path to the JSON file.
  7. * @param callable $dataCallback A callback function that processes each JSON object. Receives the object as an argument.
  8. * @param int $maxRetries The maximum number of retry attempts.
  9. * @param int $retryDelay The delay in seconds between retries.
  10. * @return bool True on success, false on failure.
  11. */
  12. function importJsonData(string $jsonFilePath, callable $dataCallback, int $maxRetries = 3, int $retryDelay = 5): bool
  13. {
  14. $totalRetries = 0;
  16. while ($totalRetries < $maxRetries) {
  17. try {
  18. // Read the JSON file
  19. $jsonData = file_get_contents($jsonFilePath);
  21. if ($jsonData === false) {
  22. error_log("Error reading JSON file: " . $jsonFilePath);
  23. $totalRetries++;
  24. if ($totalRetries < $maxRetries) {
  25. sleep($retryDelay);
  26. }
  27. continue; // Retry
  28. }
  30. // Decode the JSON data
  31. $data = json_decode($jsonData, true);
  33. if ($data === null) {
  34. $error = json_last_error_msg();
  35. error_log("Error decoding JSON: " . $error);
  36. $totalRetries++;
  37. if ($totalRetries < $maxRetries) {
  38. sleep($retryDelay);
  39. }
  40. continue; // Retry
  41. }
  43. // Process each JSON object
  44. if (is_array($data)) {
  45. foreach ($data as $item) {
  46. $dataCallback($item); // Call the provided callback function
  47. }
  48. } else {
  49. $dataCallback($data); // If not an array, treat it as a single object.
  50. }
  52. return true; // Success
  53. } catch (Exception $e) {
  54. error_log("An unexpected error occurred: " . $e->getMessage());
  55. $totalRetries++;
  56. if ($totalRetries < $maxRetries) {
  57. sleep($retryDelay);
  58. }
  59. continue; // Retry
  60. }
  61. }
  63. error_log("Import failed after " . $maxRetries . " retries.");
  64. return false; // Failure
  65. }
  69. /**
  70. * Example usage (replace with your actual data processing logic)
  71. *
  72. * @param array $item A single JSON object.
  73. */
  74. function processJsonItem(array $item): void
  75. {
  76. // Your data processing logic here.
  77. echo "Processing item: " . json_encode($item) . "\n";
  78. }
  80. // Example call
  81. //$success = importJsonData('data.json', 'processJsonItem', 5, 2);
  83. ?>

Add your comment