Disk Monitor#

Disk Monitor for CCAT Data Transfer System

This module implements disk usage monitoring for all DiskDataLocation instances using the new Site/DataLocation architecture and dynamic queue discovery system. It monitors disk space for all active disk-based storage locations and stores the information in Redis for use by other components like the deletion manager.

ccat_data_transferccat_data_transfer.disk_monitor.monitor_all_disk_locations()#

Monitor disk usage for all active DiskDataLocation instances.

ccat_data_transferccat_data_transfer.disk_monitor.monitor_disk_location(location_id: int)#

Monitor disk usage for a specific DiskDataLocation.

Parameters:

location_id (int) – The ID of the DataLocation to monitor

ccat_data_transferccat_data_transfer.disk_monitor.monitor_disk_usage_cologne()#

Monitor disk usage for cologne archive (legacy function).

ccat_data_transferccat_data_transfer.disk_monitor.monitor_disk_usage_us()#

Monitor disk usage for us archive (legacy function).

ccat_data_transferccat_data_transfer.disk_monitor.monitor_disk_usage_fyst()#

Monitor disk usage for fyst archive (legacy function).

ccat_data_transfer.disk_monitor.get_disk_locations_for_site(session, site_short_name: str) → List[DiskDataLocation][source]#

Get all active disk locations for a specific site.

Parameters:

  • session (Session) – Database session

  • site_short_name (str) – Short name of the site (e.g., “cologne”, “us”, “apex”)

Returns:

List of active disk locations for the site

Return type:

List[models.DiskDataLocation]

ccat_data_transfer.disk_monitor.get_disk_locations_by_type(session, location_type: LocationType) → List[DiskDataLocation][source]#

Get all active disk locations of a specific type.

Parameters:

  • session (Session) – Database session

  • location_type (models.LocationType) – Type of location to filter for

Returns:

List of active disk locations of the specified type

Return type:

List[models.DiskDataLocation]

Overview#

The Disk Monitor tracks disk usage and storage capacity across all sites.

Key Functions#

  • monitor_disk_usage() - Monitor disk usage

  • check_capacity() - Check storage capacity