Function compute_log_metrics

sdk/python/feast/api/registry/rest/monitoring.py:170–201

Compute metrics from feature serving logs for a feature service.

(request: ComputeLogMetricsRequest)

    @router.post("/monitoring/compute/log", tags=["Monitoring"])
    async def compute_log_metrics(request: ComputeLogMetricsRequest):
        """Compute metrics from feature serving logs for a feature service."""
        if request.granularity not in VALID_GRANULARITIES:
            raise HTTPException(
                status_code=400,
                detail=f"Invalid granularity '{request.granularity}'. "
                f"Must be one of {VALID_GRANULARITIES}",
            )

        store = _get_store()
        fs = store.registry.get_feature_service(
            name=request.feature_service_name, project=request.project
        )
        assert_permissions(fs, actions=[AuthzedAction.UPDATE])

        svc = _get_monitoring_service()

        start_d = date.fromisoformat(request.start_date) if request.start_date else None
        end_d = date.fromisoformat(request.end_date) if request.end_date else None

        try:
            result = svc.compute_log_metrics(
                project=request.project,
                feature_service_name=request.feature_service_name,
                start_date=start_d,
                end_date=end_d,
                granularity=request.granularity,
                set_baseline=request.set_baseline,
            )
            return result
        except Exception as e:
            raise HTTPException(status_code=500, detail=str(e))

    @router.post("/monitoring/auto_compute/log", tags=["Monitoring"])
    async def auto_compute_log(request: AutoComputeLogRequest):