1. import json
  3. def process_log_stream(log_stream, fixes, fallback_handler):
  4. """
  5. Processes a log stream with nested structures, applying fixes and falling back if needed.
  7. Args:
  8. log_stream (dict): The log stream data.
  9. fixes (list): A list of fix functions.
  10. fallback_handler (callable): A function to handle cases where fixes fail.
  12. Returns:
  13. dict: The processed log stream, or None if all fixes fail.
  14. """
  15. for fix in fixes:
  16. try:
  17. processed_stream = fix(log_stream) # Apply the fix
  18. if processed_stream:
  19. return processed_stream # Fix successful, return the result
  20. except Exception as e:
  21. print(f"Fix failed: {e}")
  22. pass # Continue to the next fix
  24. # No fixes succeeded, call the fallback handler
  25. return fallback_handler(log_stream)
  27. def example_fix_1(log_stream):
  28. """Example fix function - modifies the log stream."""
  29. if 'error_code' in log_stream and log_stream['error_code'] == 'ERR_001':
  30. log_stream['status'] = 'resolved'
  31. return log_stream
  32. return None
  34. def example_fix_2(log_stream):
  35. """Example fix function - adds a new field."""
  36. if 'message' in log_stream:
  37. log_stream['timestamp'] = '2024-01-01T00:00:00Z' # Add timestamp
  38. return log_stream
  39. return None
  41. def example_fallback(log_stream):
  42. """Example fallback handler - logs the original stream."""
  43. print("Fallback: Log stream could not be processed.")
  44. print(json.dumps(log_stream, indent=2))
  45. return None
  48. if __name__ == '__main__':
  49. # Example usage
  50. log_data = {
  51. 'message': 'An error occurred.',
  52. 'error_code': 'ERR_001',
  53. 'timestamp': '2024-01-01T12:00:00Z'
  54. }
  56. fixes = [example_fix_1, example_fix_2]
  57. fallback_handler = example_fallback
  59. processed_data = process_log_stream(log_data, fixes, fallback_handler)
  61. if processed_data:
  62. print("Processed Log Data:")
  63. print(json.dumps(processed_data, indent=2))
  64. else:
  65. print("Log stream processing failed.")

Add your comment