U
h3 @ s d Z ddlmZ ddlmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
ddlmZmZ dd lmZ dd
lmZ dd lZdd lmZmZmZ dd
lmZm Z ddl m Z G dd deeZ dd Z dd Z!G dd deeZ"dd Z#dd Z$dd Z%d S ) z
Monitoring Views for Stream Processor Application
This module contains views for the monitoring dashboard, system health,
and real-time status updates using HTMX for dynamic content loading.
)render) JsonResponse HttpResponse) TemplateView)
cache_page)method_decorator)timezone)CountQ) timedelta)LoginRequiredMixinN)Channel
StreamSession
HLSSegment)JingleDetectionAdBreak) Notificationc s$ e Zd ZdZdZ fddZ ZS )
DashboardViewz
Main dashboard view showing system overview and real-time statistics.
This view provides a comprehensive overview of the stream processing
system including active streams, recent detections, and system health.
zmonitoring/dashboard.htmlc s t jf |}t }|tdd }|tdd }tjjddgd}| t jjdd tjj|d t
jj|d
t jj|d t jj|d d
d|d< tj
dddd |d< t
j
ddddd |d< t j
dddd |d< |
ddd |d < |S ) z
Get dashboard context data including statistics and recent activity.
Returns:
dict: Context data for the dashboard template
hours active
processing
status__inT is_activeZstarted_at__gtedetection_time__gteZstart_time__gte completed)Z sent_at__gtestatus)active_streamsZtotal_channelssessions_todaydetections_todayad_breaks_todayZnotifications_sent_todaystatschannelz -started_atN recent_sessionstemplatesession__channel-detection_timerecent_detections -start_timerecent_ad_breaks video_config audio_configr$ )superget_context_datar nowr r objectsfiltercountr
r r r select_relatedorder_by)selfkwargscontextr6 last_24h last_houractive_sessions __class__ :/var/www/html/StreamProcessor/src/apps/monitoring/views.pyr5 " sf
z DashboardView.get_context_data)__name__
__module__ __qualname____doc__
template_namer5
__classcell__rD rD rB rE r s r c C s t jjddgd }t jjdt tdd d }|dkrTd }| d
}d }n(|dkrpd }| d
}d}n d}d}d}d| d| d}t|S )a
HTMX endpoint for real-time system status updates.
Returns system health information in HTML format for dynamic updates.
Args:
request: HTTP request object
Returns:
HttpResponse: HTML fragment with system status
r r r failedr* minutesr# Zupdated_at__gter warningz failed streamsyellowhealthyz active streamsgreenidlezNo active streamsgrayzX
)r r7 r8 r9 r r6 r r )requestr$ Zfailed_streamsr# messagecolorhtmlrD rD rE
system_status\ s0
rZ c C sn ddl }ddl}zD|jdd}| }|d}d|dd|jdd |jdd
}W n d }Y nX t|S ) z
HTMX endpoint for system information updates.
Returns basic system information for the sidebar.
Args:
request: HTTP request object
Returns:
HttpResponse: HTML fragment with system info
r Nr )interval/z?
CPU: z.1fz %
RAM: z %
Disk: z %
z<Metrics unavailable
)psutilos cpu_percentZvirtual_memory
disk_usagepercentr )rV r] r^ r_ memoryZdiskrY rD rD rE system_info s
&
rc c s< e Zd ZdZdZ fddZdd Zdd Zd d
Z Z S ) MetricsViewzA
Detailed metrics view with charts and performance data.
zmonitoring/metrics.htmlc
s6 t jf |}t }|tdd }|tdd }g }tdD ]N}|t|d d }|t|d } tjj|| d }
|
| d|
d q>t t
||d < g } tjjd
d D ]V} | jj|d }
tjj| |d
}|
| j|
| |jtddd pdd q| |d< | || || |d|d< |S )z2Get detailed metrics data for charts and analysis.r r )daysr )r Zdetection_time__ltz%H:00)hourr9 hourly_detectionsTr r )r- r confidence_score)avgrj r )namesessions
detectionsavg_confidence
channel_stats)Zdetection_accuracyZ
stream_uptimeZnotification_delivery_rateperformance_data)r4 r5 r r6 r ranger r7 r8 r9 appendstrftimelistreversedr
rl rk aggregatemodelsAvg _calculate_detection_accuracy_calculate_stream_uptime _calculate_notification_rate)r< r= r> r6 r? last_7drh iZ
hour_startZhour_endr9 ro r) rl rm rB rD rE r5 sR
z MetricsView.get_context_datac C s> t jj|d }|dkr dS t jj|dd }|| d S )z(Calculate detection accuracy percentage.r r T)r is_confirmedd )r r7 r8 r9 )r< sincetotal_detectionsconfirmed_detectionsrD rD rE ry s
z)MetricsView._calculate_detection_accuracyc C sv t jj|d}| sdS d}d}|D ]2}| r&| }|jdkrP||7 }|d7 }q&|dkrfdS ||d d S )z+Calculate average stream uptime percentage.r r )r r" r i r )r r7 r8 existsduration
total_secondsr# )r< r rl Z total_uptimeZtotal_sessionssessionr rD rD rE rz s
z$MetricsView._calculate_stream_uptimec C s: t jj|d}| sdS |jdd }|| d S )z-Calculate notification delivery success rate.)created_at__gter r" r# r )r r7 r8 r r9 )r< r
notificationssent_notificationsrD rD rE r{ s
z(MetricsView._calculate_notification_rate)
rF rG rH rI rJ r5 ry rz r{ rK rD rD rB rE rd s 8rd c
C s dt di d}z:ddlm} | }|d W 5 Q R X d|d d< W n@ tk
r } z"d t| |d d< d
|d < W 5 d }~X Y nX z8dd l }dd
l
m } | |j
}| d|d d< W nB tk
r } z"d t| |d d< d|d < W 5 d }~X Y nX tjjddgd }||d d< tjjdt tdd d } | dkrxd|d < d| |d d< nd| |d d< |d dkrdnd }
t||
d S ) z
Health check endpoint for load balancers and monitoring systems.
Args:
request: HTTP request object
Returns:
JsonResponse: Health status and system information
rR z1.0.0)r# timestampversionchecksr )
connectionzSELECT 1r databasez unhealthy: Z unhealthyr# N)settingsredisZdegradedr r r r$ rL r* rM rO zhigh: recent_failuresznormal: i r )r r6 isoformat django.dbr cursorexecute Exceptionstrr django.confr from_urlCELERY_BROKER_URLpingr r7 r8 r9 r r ) rV Z health_datar r er r rr$ r status_coderD rD rE health_check sH
r c C s2 t jjddgdd}|| d}t| d|S )z
HTMX endpoint for live stream data updates.
Returns real-time stream information for dashboard widgets.
Args:
request: HTTP request object
Returns:
HttpResponse: HTML fragment with live stream data
r r r r) )rA Z total_activez%monitoring/partials/live_streams.html)r r7 r8 r: r9 r )rV rA r> rD rD rE live_stream_data[ s r c C sn t tdd }tjj|dddddd }tjj|d dd
dd }||d }t | d
|S )z
HTMX endpoint for recent activity updates.
Returns recent detections and events for the activity feed.
Args:
request: HTTP request object
Returns:
HttpResponse: HTML fragment with recent activity
r r r r, r- r. N
r! r0 r* )r/ r1 z(monitoring/partials/recent_activity.html)
r r6 r r r7 r8 r: r; r r )rV r@ r/ r1 r> rD rD rE recent_activitys s0
r )&rI django.shortcutsr django.httpr r Zdjango.views.genericr django.views.decorators.cacher django.utils.decoratorsr django.utilsr django.db.modelsr r
datetimer django.contrib.auth.mixinsr jsonZapps.streams.modelsr
r r apps.jingles.modelsr r Zapps.notifications.modelsr r rZ rc rd r r r rD rD rD rE s( D."q>