batch_get_record `async` ¶

batch_get_record(
    *,
    config_overrides: Optional[AsyncSageMakerFeatureStoreRuntimeClientConfig] = None,
    identifiers: Optional[BatchGetRecordIdentifiers] = None,
    expiration_time_response: Optional[ExpirationTimeResponse] = None,
) -> BatchGetRecordResponse

Retrieves a batch of Records from a FeatureGroup.

Parameters:

identifiers (Optional[BatchGetRecordIdentifiers], default: None ) –

A list containing the name or Amazon Resource Name (ARN) of the FeatureGroup, the list of names of Features to be retrieved, and the corresponding RecordIdentifier values as strings.
expiration_time_response (Optional[ExpirationTimeResponse], default: None ) –

Parameter to request ExpiresAt in response. If Enabled, BatchGetRecord will return the value of ExpiresAt, if it is not null. If Disabled and null, BatchGetRecord will return null.

Raises:

AccessForbidden –

You do not have permission to perform an action.
InternalFailure –

An internal failure occurred. Try your request again. If the problem persists, contact Amazon Web Services customer support.
ServiceUnavailable –

The service is currently unavailable.
ValidationError –

There was an error validating your request.
UnknownServiceError –

The service returned an error code this client does not model.

Source code in docs_src/capo_sagemaker_featurestore_runtime/_services/async_sage_maker_feature_store_runtime.py

async def batch_get_record(
    self,
    *,
    config_overrides: Optional[
        AsyncSageMakerFeatureStoreRuntimeClientConfig
    ] = None,
    identifiers: Optional[
        "capo_sagemaker_featurestore_runtime.types.batch_get_record_identifiers.BatchGetRecordIdentifiers"
    ] = None,
    expiration_time_response: Optional[
        "capo_sagemaker_featurestore_runtime.types.expiration_time_response.ExpirationTimeResponse"
    ] = None,
) -> "capo_sagemaker_featurestore_runtime.types.batch_get_record_response.BatchGetRecordResponse":
    """<p>Retrieves a batch of <code>Records</code> from a <code>FeatureGroup</code>.</p>

    Args:
        identifiers: <p>A list containing the name or Amazon Resource Name (ARN) of the <code>FeatureGroup</code>, the list of names of <code>Feature</code>s to be retrieved, and the corresponding <code>RecordIdentifier</code> values as strings.</p>
        expiration_time_response: <p>Parameter to request <code>ExpiresAt</code> in response. If <code>Enabled</code>, <code>BatchGetRecord</code> will return the value of <code>ExpiresAt</code>, if it is not null. If <code>Disabled</code> and null, <code>BatchGetRecord</code> will return null.</p>

    Raises:
        capo_sagemaker_featurestore_runtime.errors.access_forbidden.AccessForbidden: <p>You do not have permission to perform an action.</p>
        capo_sagemaker_featurestore_runtime.errors.internal_failure.InternalFailure: <p>An internal failure occurred. Try your request again. If the problem persists, contact Amazon Web Services customer support.</p>
        capo_sagemaker_featurestore_runtime.errors.service_unavailable.ServiceUnavailable: <p>The service is currently unavailable.</p>
        capo_sagemaker_featurestore_runtime.errors.validation_error.ValidationError: <p>There was an error validating your request.</p>
        capo_sagemaker_featurestore_runtime.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_sagemaker_featurestore_runtime.types.batch_get_record_request.BatchGetRecordRequest]",
    ) -> AsyncOperationResponse[
        "capo_sagemaker_featurestore_runtime.types.batch_get_record_response.BatchGetRecordResponse"
    ]:
        import capo_sagemaker_featurestore_runtime._operations.amazon_sage_maker_feature_store_runtime.batch_get_record

        (
            output,
            http_response,
        ) = await capo_sagemaker_featurestore_runtime._operations.amazon_sage_maker_feature_store_runtime.batch_get_record.async_batch_get_record(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("BatchGetRecord")
    )
    input_: capo_sagemaker_featurestore_runtime.types.batch_get_record_request.BatchGetRecordRequest = {}
    if identifiers is not None:
        input_["identifiers"] = identifiers
    if expiration_time_response is not None:
        input_["expiration_time_response"] = expiration_time_response

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output

batch_get_record async ¶

batch_get_record `async` ¶