Function get_online_features

sdk/python/feast/feature_server.py:417–457

(request: GetOnlineFeaturesRequest)

        response_model=OnlineFeaturesResponse,
    )
    async def get_online_features(request: GetOnlineFeaturesRequest) -> Any:
        with feast_metrics.track_request_latency(
            "/get-online-features",
        ) as metrics_ctx:
            features = await _get_features(request, store)
            feat_count, fv_count = _resolve_feature_counts(features)
            metrics_ctx.feature_count = feat_count
            metrics_ctx.feature_view_count = fv_count

            entity_count = len(next(iter(request.entities.values()), []))
            feast_metrics.track_online_features_entities(entity_count)

            read_params = dict(
                features=features,
                entity_rows=request.entities,
                full_feature_names=request.full_feature_names,
                include_feature_view_version_metadata=request.include_feature_view_version_metadata,
            )

            audit_start_ms = time.monotonic() * 1000
            audit_status = "success"
            try:
                if store._get_provider().async_supported.online.read:
                    response = await store.get_online_features_async(**read_params)  # type: ignore
                else:
                    response = await run_in_threadpool(
                        lambda: store.get_online_features(**read_params)  # type: ignore
                    )
            except Exception:
                audit_status = "error"
                raise
            finally:
                audit_latency_ms = time.monotonic() * 1000 - audit_start_ms
                _emit_online_audit(
                    request, features, entity_count, audit_status, audit_latency_ms
                )

            response_dict = await run_in_threadpool(
                convert_response_to_dict, response.proto
            )
            return JSONResponse(content=response_dict)

    @app.post(
        "/retrieve-online-documents",