1. import time
  2. import os
  3. import logging
  5. def retry_log_operation(filepath, operation, max_retries=3, timeout=10):
  6. """
  7. Retries an operation on a log file with a timeout.
  9. Args:
  10. filepath (str): Path to the log file.
  11. operation (callable): Function to perform on the log file.
  12. max_retries (int): Maximum number of retries.
  13. timeout (int): Timeout in seconds for each retry.
  15. Returns:
  16. The result of the operation if successful, None otherwise.
  17. """
  18. for attempt in range(max_retries):
  19. try:
  20. # Attempt the operation
  21. result = operation(filepath)
  22. logging.info(f"Operation successful on attempt {attempt + 1}")
  23. return result
  24. except Exception as e:
  25. logging.warning(f"Operation failed on attempt {attempt + 1}: {e}")
  26. if attempt < max_retries - 1:
  27. logging.info(f"Retrying in {timeout} seconds...")
  28. time.sleep(timeout)
  29. else:
  30. logging.error(f"Operation failed after {max_retries} attempts.")
  31. return None
  33. def read_log_file_with_timeout(filepath, timeout):
  34. """Reads a log file, retrying if it fails."""
  35. def read_file(file_path):
  36. try:
  37. with open(file_path, 'r') as f:
  38. content = f.read()
  39. return content
  40. except Exception as e:
  41. raise e # Re-raise to be handled by retry_log_operation
  43. return retry_log_operation(filepath, read_file, timeout=timeout)
  45. def parse_log_file_with_timeout(filepath, parsing_function, timeout):
  46. """Parses a log file, retrying if it fails."""
  47. def parse_file(file_path):
  48. try:
  49. return parsing_function(file_path)
  50. except Exception as e:
  51. raise e # Re-raise to be handled by retry_log_operation
  52. return retry_log_operation(filepath, parse_file, timeout=timeout)
  54. if __name__ == '__main__':
  55. #Example Usage
  56. log_file = "my_log.txt"
  58. #Create a dummy log file for testing
  59. with open(log_file, "w") as f:
  60. f.write("This is a log entry.\n")
  62. # Example 1: Read the log file
  63. content = read_log_file_with_timeout(log_file, timeout=5)
  64. if content:
  65. print("Log file content:")
  66. print(content)
  67. else:
  68. print("Failed to read log file after retries.")
  70. # Example 2: Parse the log file
  71. def parse_line(line):
  72. return line.split(',')
  74. parsed_data = parse_log_file_with_timeout(log_file, parse_line, timeout=5)
  75. if parsed_data:
  76. print("Parsed data:")
  77. print(parsed_data)
  78. else:
  79. print("Failed to parse log file after retries.")
  81. #Clean up the dummy log file
  82. os.remove(log_file)

Add your comment