1. import time
  2. import logging
  4. # Configure logging
  5. logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
  8. def validate_user_record(user_record):
  9. """
  10. Validates a user record. Returns True if valid, False otherwise.
  11. Raises an exception if validation fails.
  12. """
  13. if not isinstance(user_record, dict):
  14. raise ValueError("User record must be a dictionary.")
  15. if not all(key in user_record for key in ("user_id", "email", "name")):
  16. raise ValueError("User record missing required fields (user_id, email, name).")
  17. if not isinstance(user_record["user_id"], (int, str)):
  18. raise ValueError("user_id must be an integer or string.")
  19. if not isinstance(user_record["email"], str):
  20. raise ValueError("email must be a string.")
  21. if not user_record["email"].contains("@"):
  22. raise ValueError("Invalid email format.")
  23. if not isinstance(user_record["name"], str):
  24. raise ValueError("name must be a string.")
  25. return True
  28. def process_user_record(user_record, max_retries=3, retry_interval=5):
  29. """
  30. Processes a user record with retry logic for validation errors.
  31. """
  32. for attempt in range(max_retries):
  33. try:
  34. validate_user_record(user_record)
  35. logging.info(f"User record validated successfully: {user_record}")
  36. return True # Record is valid
  37. except ValueError as e:
  38. logging.warning(f"Validation failed (attempt {attempt + 1}/{max_retries}): {e}")
  39. if attempt < max_retries - 1:
  40. time.sleep(retry_interval) # Wait before retrying
  41. else:
  42. logging.error(f"Validation failed after {max_retries} attempts: {e}")
  43. return False # Record is invalid after all retries
  47. if __name__ == '__main__':
  48. # Example Usage
  49. user_record1 = {"user_id": 123, "email": "test@example.com", "name": "John Doe"}
  50. user_record2 = {"user_id": "abc", "email": "invalid-email", "name": 123} # Invalid record
  51. user_record3 = {"user_id": 456, "email": "valid@example.com", "name": "Jane Smith"}
  53. print(f"Processing record 1: {process_user_record(user_record1)}")
  54. print(f"Processing record 2: {process_user_record(user_record2)}")
  55. print(f"Processing record 3: {process_user_record(user_record3)}")

Add your comment