Notification Service#

class ccat_data_transfer.notification_service.NotificationService[source]#

Bases: object

Service to handle email notifications from pipeline components.

__init__()[source]#

Initialize the notification service.

start(verbose=False)[source]#

Start the notification service.

stop()[source]#

Stop the notification service.

class ccat_data_transfer.notification_service.NotificationClient(redis_client=None)[source]#

Bases: object

Client to send notifications to the notification service.

__init__(redis_client=None)[source]#

Initialize the notification client.

Parameters:

redis_client – Optional Redis client. If not provided, a new one will be created.

send_notification(subject: str, body: str, level: str = 'ERROR', recipients: List[str] | None = None)[source]#

Send a notification.

Parameters:

  • subject – Email subject

  • body – Email body

  • level – Notification level (ERROR, CRITICAL, WARNING, INFO)

  • recipients – Optional list of recipient email addresses

Overview#

System notifications and alerts for the data transfer system.

Key Components#

  • Notification delivery

  • Alert management

  • Notification templates and formatting