get_asset async ¶

async def get_asset(
    self,
    domain_identifier: "capo_datazone.types.domain_id.DomainId",
    identifier: "capo_datazone.types.asset_identifier.AssetIdentifier",
    *,
    config_overrides: Optional[AsyncDataZoneClientConfig] = None,
    revision: Optional["capo_datazone.types.revision.Revision"] = None,
) -> "capo_datazone.types.get_asset_output.GetAssetOutput":
    """<p>Gets an Amazon DataZone asset.</p> <p>An asset is the fundamental building block in Amazon DataZone, representing any data resource that needs to be cataloged and managed. It can take many forms, from Amazon S3 buckets and database tables to dashboards and machine learning models. Each asset contains comprehensive metadata about the resource, including its location, schema, ownership, and lineage information. Assets are essential for organizing and managing data resources across an organization, making them discoverable and usable while maintaining proper governance.</p> <p>Before using the Amazon DataZone GetAsset command, ensure the following prerequisites are met:</p> <ul> <li> <p>Domain identifier must exist and be valid</p> </li> <li> <p>Asset identifier must exist</p> </li> <li> <p>User must have the required permissions to perform the action</p> </li> </ul>

    Args:
        domain_identifier: <p>The ID of the Amazon DataZone domain to which the asset belongs.</p>
        identifier: <p>The ID of the Amazon DataZone asset.</p> <p>This parameter supports either the value of <code>assetId</code> or <code>externalIdentifier</code> as input. If you are passing the value of <code>externalIdentifier</code>, you must prefix this value with <code>externalIdentifer%2F</code>.</p>
        revision: <p>The revision of the Amazon DataZone asset.</p>

    Raises:
        capo_datazone.errors.access_denied_exception.AccessDeniedException: <p>You do not have sufficient access to perform this action.</p>
        capo_datazone.errors.throttling_exception.ThrottlingException: <p>The request was denied due to request throttling.</p>
        capo_datazone.errors.unauthorized_exception.UnauthorizedException: <p>You do not have permission to perform this action.</p>
        capo_datazone.errors.internal_server_exception.InternalServerException: <p>The request has failed because of an unknown error, exception or failure.</p>
        capo_datazone.errors.resource_not_found_exception.ResourceNotFoundException: <p>The specified resource cannot be found.</p>
        capo_datazone.errors.validation_exception.ValidationException: <p>The input fails to satisfy the constraints specified by the Amazon Web Services service.</p>
        capo_datazone.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_datazone.types.get_asset_input.GetAssetInput]",
    ) -> AsyncOperationResponse[
        "capo_datazone.types.get_asset_output.GetAssetOutput"
    ]:
        import capo_datazone._operations.data_zone.get_asset

        (
            output,
            http_response,
        ) = await capo_datazone._operations.data_zone.get_asset.async_get_asset(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_output(
        output: "capo_datazone.types.get_asset_output.GetAssetOutput",
    ) -> dict[str, Any]:
        import capo_datazone.types.get_asset_output

        return capo_datazone.types.get_asset_output.redact_sensitive(output)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("GetAsset", redact_output=_redact_output)
    )
    input_: capo_datazone.types.get_asset_input.GetAssetInput = {
        "domain_identifier": domain_identifier,
        "identifier": identifier,
    }
    if revision is not None:
        input_["revision"] = revision

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