1. import os
  2. import time
  3. import logging
  5. def release_log_resources(log_dir, max_age_days=30, fallback_action="warn"):
  6. """
  7. Releases resources of log files older than max_age_days.
  9. Args:
  10. log_dir (str): The directory containing the log files.
  11. max_age_days (int): The maximum age of log files in days.
  12. fallback_action (str): "warn", "error", or "ignore".
  13. Determines the action if deletion fails.
  14. """
  16. now = time.time()
  17. cutoff_time = now - (max_age_days * 24 * 60 * 60) # Calculate cutoff time
  19. for filename in os.listdir(log_dir):
  20. if filename.endswith(".log"):
  21. filepath = os.path.join(log_dir, filename)
  22. try:
  23. # Get file modification time
  24. file_modified_time = os.path.getmtime(filepath)
  26. # Check if the file is older than the cutoff
  27. if file_modified_time < cutoff_time:
  28. try:
  29. os.remove(filepath) # Delete the file
  30. print(f"Deleted log file: {filepath}")
  31. except OSError as e:
  32. if fallback_action == "warn":
  33. logging.warning(f"Failed to delete {filepath}: {e}")
  34. elif fallback_action == "error":
  35. logging.error(f"Failed to delete {filepath}: {e}")
  36. elif fallback_action == "ignore":
  37. pass # Do nothing
  38. else:
  39. logging.error(f"Invalid fallback action: {fallback_action}")
  41. except OSError as e:
  42. if fallback_action == "warn":
  43. logging.warning(f"Failed to get modification time for {filepath}: {e}")
  44. elif fallback_action == "error":
  45. logging.error(f"Failed to get modification time for {filepath}: {e}")
  46. elif fallback_action == "ignore":
  47. pass
  48. else:
  49. logging.error(f"Invalid fallback action: {fallback_action}")
  51. if __name__ == "__main__":
  52. # Example usage
  53. log_directory = "legacy_logs" # Replace with your log directory
  55. # Create the directory if it doesn't exist
  56. if not os.path.exists(log_directory):
  57. os.makedirs(log_directory)
  59. # Create some dummy log files for testing
  60. with open(os.path.join(log_directory, "log1.log"), "w") as f:
  61. f.write("This is log file 1")
  62. time.sleep(35)
  63. with open(os.path.join(log_directory, "log2.log"), "w") as f:
  64. f.write("This is log file 2")
  65. time.sleep(5)
  67. release_log_resources(log_directory, max_age_days=30, fallback_action="warn")

Add your comment