Skip to content

update_integration_resource_property async

update_integration_resource_property(
    resource_arn: String512,
    *,
    config_overrides: Optional[AsyncGlueClientConfig] = None,
    source_processing_properties: Optional[SourceProcessingProperties] = None,
    target_processing_properties: Optional[TargetProcessingProperties] = None,
) -> UpdateIntegrationResourcePropertyResponse

This API can be used for updating the ResourceProperty of the Glue connection (for the source) or Glue database ARN (for the target). These properties can include the role to access the connection or database. Since the same resource can be used across multiple integrations, updating resource properties will impact all the integrations using it.

Parameters:

  • resource_arn (String512) –

    The connection ARN of the source, or the database ARN of the target.

  • source_processing_properties (Optional[SourceProcessingProperties], default: None ) –

    The resource properties associated with the integration source.

  • target_processing_properties (Optional[TargetProcessingProperties], default: None ) –

    The resource properties associated with the integration target.

Raises:

Source code in docs_src/capo_glue/_services/async_glue.py
async def update_integration_resource_property(
    self,
    resource_arn: "capo_glue.types.string512.String512",
    *,
    config_overrides: Optional[AsyncGlueClientConfig] = None,
    source_processing_properties: Optional[
        "capo_glue.types.source_processing_properties.SourceProcessingProperties"
    ] = None,
    target_processing_properties: Optional[
        "capo_glue.types.target_processing_properties.TargetProcessingProperties"
    ] = None,
) -> "capo_glue.types.update_integration_resource_property_response.UpdateIntegrationResourcePropertyResponse":
    """<p>This API can be used for updating the <code>ResourceProperty</code> of the Glue connection (for the source) or Glue database ARN (for the target). These properties can include the role to access the connection or database. Since the same resource can be used across multiple integrations, updating resource properties will impact all the integrations using it.</p>

    Args:
        resource_arn: <p>The connection ARN of the source, or the database ARN of the target.</p>
        source_processing_properties: <p>The resource properties associated with the integration source.</p>
        target_processing_properties: <p>The resource properties associated with the integration target.</p>

    Raises:
        capo_glue.errors.access_denied_exception.AccessDeniedException: <p>Access to a resource was denied.</p>
        capo_glue.errors.entity_not_found_exception.EntityNotFoundException: <p>A specified entity does not exist</p>
        capo_glue.errors.internal_server_exception.InternalServerException: <p>An internal server error occurred.</p>
        capo_glue.errors.internal_service_exception.InternalServiceException: <p>An internal service error occurred.</p>
        capo_glue.errors.invalid_input_exception.InvalidInputException: <p>The input provided was not valid.</p>
        capo_glue.errors.resource_not_found_exception.ResourceNotFoundException: <p>The resource could not be found.</p>
        capo_glue.errors.validation_exception.ValidationException: <p>A value could not be validated.</p>
        capo_glue.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_glue.types.update_integration_resource_property_request.UpdateIntegrationResourcePropertyRequest]",
    ) -> AsyncOperationResponse[
        "capo_glue.types.update_integration_resource_property_response.UpdateIntegrationResourcePropertyResponse"
    ]:
        import capo_glue._operations.aws_glue.update_integration_resource_property

        (
            output,
            http_response,
        ) = await capo_glue._operations.aws_glue.update_integration_resource_property.async_update_integration_resource_property(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("UpdateIntegrationResourceProperty")
    )
    input_: capo_glue.types.update_integration_resource_property_request.UpdateIntegrationResourcePropertyRequest = {
        "resource_arn": resource_arn
    }
    if source_processing_properties is not None:
        input_["source_processing_properties"] = source_processing_properties
    if target_processing_properties is not None:
        input_["target_processing_properties"] = target_processing_properties

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