1. <?php
  3. /**
  4. * Aggregates values from text files with rate limiting.
  5. *
  6. * @param array $filePaths An array of file paths to aggregate.
  7. * @param int $requestsPerSecond The maximum number of requests allowed per second.
  8. * @return array An associative array where keys are file paths and values are the aggregated data.
  9. * Returns an empty array on error.
  10. */
  11. function aggregateTextFilesWithRateLimit(array $filePaths, int $requestsPerSecond): array
  12. {
  13. $results = [];
  14. $rateLimit = new RateLimit(1, $requestsPerSecond); // Initialize rate limiter
  16. foreach ($filePaths as $filePath) {
  17. try {
  18. $data = readAndAggregateFile($filePath);
  19. $results[$filePath] = $data;
  20. } catch (Exception $e) {
  21. error_log("Error processing file {$filePath}: " . $e->getMessage());
  22. // Handle the error appropriately (e.g., log, skip, or retry)
  23. continue; // Skip to the next file
  24. }
  26. $rateLimit->wait(); // Wait if rate limit is exceeded
  27. }
  29. return $results;
  30. }
  32. /**
  33. * Reads a text file and aggregates its content.
  34. *
  35. * @param string $filePath The path to the text file.
  36. * @return string The aggregated content of the file.
  37. * @throws Exception If the file cannot be read.
  38. */
  39. function readAndAggregateFile(string $filePath): string
  40. {
  41. $content = file_get_contents($filePath);
  43. if ($content === false) {
  44. throw new Exception("Failed to read file: {$filePath}");
  45. }
  47. // Perform aggregation logic here. This is a placeholder.
  48. // Replace with your specific aggregation requirements.
  49. return strtoupper($content); // Example: Convert to uppercase
  50. }
  53. /**
  54. * Simple Rate Limiter class
  55. */
  56. class RateLimit {
  57. private $capacity;
  58. private $rate;
  59. private $tokens;
  60. private $lastReset;
  62. public function __construct(int $capacity, int $rate) {
  63. $this->capacity = $capacity;
  64. $this->rate = $rate;
  65. $this->tokens = $capacity;
  66. $this->lastReset = time();
  67. }
  69. public function wait(): void {
  70. $now = time();
  71. $timePassed = $now - $this->lastReset;
  72. $tokensToAdd = $timePassed * $this->rate;
  74. $this->tokens = min($this->capacity, $this->tokens + $tokensToAdd);
  75. $this->lastReset = $now;
  77. if ($this->tokens < 1) {
  78. $sleep = 1000 / $this->rate; // Calculate sleep time
  79. usleep($sleep * 1000000); // Sleep for calculated time
  80. }
  81. }
  82. }
  86. // Example Usage (replace with your actual file paths and rate limit)
  87. $filePaths = [
  88. 'file1.txt',
  89. 'file2.txt',
  90. 'file3.txt',
  91. ];
  93. // Create dummy files for testing
  94. file_put_contents('file1.txt', 'This is file 1.');
  95. file_put_contents('file2.txt', 'This is file 2.');
  96. file_put_contents('file3.txt', 'This is file 3.');
  99. $requestsPerSecond = 2;
  101. $aggregatedData = aggregateTextFilesWithRateLimit($filePaths, $requestsPerSecond);
  103. print_r($aggregatedData);
  105. ?>

Add your comment