update_asset `async` ¶

update_asset(
    asset_id: Id,
    data_set_id: Id,
    name: AssetName,
    revision_id: Id,
    *,
    config_overrides: Optional[AsyncDataExchangeClientConfig] = None,
) -> UpdateAssetResponse

This operation updates an asset.

Parameters:

asset_id (Id) –

The unique identifier for an asset.
data_set_id (Id) –

The unique identifier for a data set.
name (AssetName) –

The name of the asset. When importing from Amazon S3, the Amazon S3 object key is used as the asset name. When exporting to Amazon S3, the asset name is used as default target Amazon S3 object key. When importing from Amazon API Gateway API, the API name is used as the asset name. When importing from Amazon Redshift, the datashare name is used as the asset name. When importing from AWS Lake Formation, the static values of "Database(s) included in the LF-tag policy" or "Table(s) included in LF-tag policy" are used as the name.
revision_id (Id) –

The unique identifier for a revision.

Raises:

AccessDeniedException –

Access to the resource is denied.
ConflictException –

The request couldn't be completed because it conflicted with the current state of the resource.
InternalServerException –

An exception occurred with the service.
ResourceNotFoundException –

The resource couldn't be found.
ThrottlingException –

The limit on the number of requests per second was exceeded.
ValidationException –

The request was invalid.
UnknownServiceError –

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

Source code in docs_src/capo_dataexchange/_services/async_data_exchange.py

async def update_asset(
    self,
    asset_id: "capo_dataexchange.types.id.Id",
    data_set_id: "capo_dataexchange.types.id.Id",
    name: "capo_dataexchange.types.asset_name.AssetName",
    revision_id: "capo_dataexchange.types.id.Id",
    *,
    config_overrides: Optional[AsyncDataExchangeClientConfig] = None,
) -> "capo_dataexchange.types.update_asset_response.UpdateAssetResponse":
    """<p>This operation updates an asset.</p>

    Args:
        asset_id: <p>The unique identifier for an asset.</p>
        data_set_id: <p>The unique identifier for a data set.</p>
        name: <p>The name of the asset. When importing from Amazon S3, the Amazon S3 object key is used as the asset name. When exporting to Amazon S3, the asset name is used as default target Amazon S3 object key. When importing from Amazon API Gateway API, the API name is used as the asset name. When importing from Amazon Redshift, the datashare name is used as the asset name. When importing from AWS Lake Formation, the static values of "Database(s) included in the LF-tag policy" or "Table(s) included in LF-tag policy" are used as the name.</p>
        revision_id: <p>The unique identifier for a revision.</p>

    Raises:
        capo_dataexchange.errors.access_denied_exception.AccessDeniedException: <p>Access to the resource is denied.</p>
        capo_dataexchange.errors.conflict_exception.ConflictException: <p>The request couldn't be completed because it conflicted with the current state of the resource.</p>
        capo_dataexchange.errors.internal_server_exception.InternalServerException: <p>An exception occurred with the service.</p>
        capo_dataexchange.errors.resource_not_found_exception.ResourceNotFoundException: <p>The resource couldn't be found.</p>
        capo_dataexchange.errors.throttling_exception.ThrottlingException: <p>The limit on the number of requests per second was exceeded.</p>
        capo_dataexchange.errors.validation_exception.ValidationException: <p>The request was invalid.</p>
        capo_dataexchange.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_dataexchange.types.update_asset_request.UpdateAssetRequest]",
    ) -> AsyncOperationResponse[
        "capo_dataexchange.types.update_asset_response.UpdateAssetResponse"
    ]:
        import capo_dataexchange._operations.data_exchange.update_asset

        (
            output,
            http_response,
        ) = await capo_dataexchange._operations.data_exchange.update_asset.async_update_asset(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("UpdateAsset")
    )
    input_: capo_dataexchange.types.update_asset_request.UpdateAssetRequest = {
        "asset_id": asset_id,
        "data_set_id": data_set_id,
        "name": name,
        "revision_id": revision_id,
    }

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

update_asset async ¶

update_asset `async` ¶