How malik-xae-12/mymonitor works
This is a Microsoft Fabric pipeline monitoring hub with an administrative console. A user selects a workspace; the frontend loads monitoring data and receives workspace updates, then presents pipeline hierarchy, runs, schedules, incidents and metrics. Backend routes combine Fabric queries with cached history and configuration, while background polling and alert monitoring support live operations. The tree and excerpts identify auth, RBAC, directory search, table-log and AI-diagnostic capabilities, but do not show all their internal wiring; those branches are represented only where paths and calls are supported.
Main entry points: routes_workspaces.py Workspace routes · main.py Service startup · App.jsx Application shell · db_service.py Monitoring data access
Components 29
Monitoring interface
- Application shell
frontend/src/App.jsx - Workspace monitor
frontend/src/hooks/useWorkspaceMonitoring.js - Pipeline monitoring
frontend/src/components/PipelineTreeTable.jsx - Pipeline details
frontend/src/components/PipelineRow.jsx - Schedule views
frontend/src/components/PipelineScheduleModal.jsx - Admin console
frontend/src/features/admin/AdminConsole.jsx - Pipeline assignments
frontend/src/features/admin/PipelineTeamsPage.jsx - API client
frontend/src/services/api/apiClient.js
Monitoring backend
- Workspace routes
backend/app/api/routes_workspaces.py - Directory routes
backend/app/api/routes_directory.py - Service startup
backend/app/main.py - Fabric client
backend/app/services/fabric_client.py - Leased poller
backend/app/services/leased_poller.py - SLA alerts
backend/app/services/alert_service.py - Pipeline tree builder
backend/app/services/tree_builder.py - AI diagnostics
backend/app/services/ai_diagnostic_service.py - Table log service
backend/app/services/table_log_service.py
Persistence and realtime
- Monitoring data access
backend/app/services/db_service.py - SQLite store
- Workspace WebSocket
backend/app/api/websocket_hub.py - Connection manager
backend/app/services/connection_manager.py
Identity and administration
- Authentication
backend/app/modules/auth/service.py - User and role service
backend/app/modules/users/service.py - User repository
backend/app/modules/users/repository.py - Directory service
backend/app/services/directory_service.py
External services
- Microsoft Fabric
- Entra ID
- Gemini service
Other components
- Monitoring user
Connections 29
- Monitoring user → Application shell: uses
- Application shell → Workspace monitor: loads monitoring
- Application shell → Pipeline monitoring: renders pipelines
- Pipeline monitoring → Pipeline details: renders rows
- Pipeline details → Schedule views: opens schedules
- Workspace monitor → Workspace routes: fetches snapshots
- Workspace monitor → Workspace WebSocket: opens workspace socket
- Workspace routes → Fabric client: queries Fabric
- Workspace routes → Monitoring data access: reads cached data
- Workspace routes → Pipeline tree builder: builds date tree
- Monitoring data access → SQLite store: reads and writes
- Service startup → Monitoring data access: initializes store
- Service startup → Leased poller: starts polling
- Service startup → SLA alerts: starts alerts
- Leased poller → Fabric client: polls Fabric
- SLA alerts → Monitoring data access: reads monitoring data
- Workspace WebSocket → Connection manager: manages clients
- Admin console → Pipeline assignments: shows assignments
- Pipeline assignments → Workspace routes: loads assignments
- Application shell → Authentication: uses identity
- Authentication → User and role service: resolves user
- User and role service → User repository: reads and writes
- User repository → SQLite store: reads and writes
- Directory routes → Directory service: searches users
- Directory service → Entra ID: searches directory
- Workspace routes → Table log service: serves table logs
- Service startup → AI diagnostics: dispatches diagnostics
- AI diagnostics → Gemini service: analyzes failures
- Fabric client → Microsoft Fabric: calls API