update_replication_configuration async ¶

async def update_replication_configuration(
    self,
    source_server_id: "capo_mgn.types.source_server_id.SourceServerID",
    *,
    config_overrides: Optional[AsyncmgnClientConfig] = None,
    name: Optional["capo_mgn.types.small_bounded_string.SmallBoundedString"] = None,
    staging_area_subnet_id: Optional["capo_mgn.types.subnet_id.SubnetID"] = None,
    associate_default_security_group: Optional[bool] = None,
    replication_servers_security_groups_i_ds: Optional[
        "capo_mgn.types.replication_servers_security_groups_i_ds.ReplicationServersSecurityGroupsIDs"
    ] = None,
    replication_server_instance_type: Optional[
        "capo_mgn.types.ec2_instance_type.EC2InstanceType"
    ] = None,
    use_dedicated_replication_server: Optional[bool] = None,
    default_large_staging_disk_type: Optional[
        "capo_mgn.types.replication_configuration_default_large_staging_disk_type.ReplicationConfigurationDefaultLargeStagingDiskType"
    ] = None,
    replicated_disks: Optional[
        "capo_mgn.types.replication_configuration_replicated_disks.ReplicationConfigurationReplicatedDisks"
    ] = None,
    ebs_encryption: Optional[
        "capo_mgn.types.replication_configuration_ebs_encryption.ReplicationConfigurationEbsEncryption"
    ] = None,
    ebs_encryption_key_arn: Optional["capo_mgn.types.arn.ARN"] = None,
    bandwidth_throttling: Optional[
        "capo_mgn.types.bandwidth_throttling.BandwidthThrottling"
    ] = None,
    data_plane_routing: Optional[
        "capo_mgn.types.replication_configuration_data_plane_routing.ReplicationConfigurationDataPlaneRouting"
    ] = None,
    create_public_ip: Optional[bool] = None,
    staging_area_tags: Optional["capo_mgn.types.tags_map.TagsMap"] = None,
    use_fips_endpoint: Optional[bool] = None,
    account_id: Optional["capo_mgn.types.account_id.AccountID"] = None,
    internet_protocol: Optional[
        "capo_mgn.types.internet_protocol.InternetProtocol"
    ] = None,
    store_snapshot_on_local_zone: Optional[bool] = None,
    storage_configuration: Optional[
        "capo_mgn.types.storage_configuration.StorageConfiguration"
    ] = None,
) -> "capo_mgn.types.replication_configuration.ReplicationConfiguration":
    """<p>Allows you to update multiple ReplicationConfigurations by Source Server ID.</p>

    Args:
        source_server_id: <p>Update replication configuration Source Server ID request.</p>
        name: <p>Update replication configuration name request.</p>
        staging_area_subnet_id: <p>Update replication configuration Staging Area subnet request.</p>
        associate_default_security_group: <p>Update replication configuration associate default Application Migration Service Security group request.</p>
        replication_servers_security_groups_i_ds: <p>Update replication configuration Replication Server Security Groups IDs request.</p>
        replication_server_instance_type: <p>Update replication configuration Replication Server instance type request.</p>
        use_dedicated_replication_server: <p>Update replication configuration use dedicated Replication Server request.</p>
        default_large_staging_disk_type: <p>Update replication configuration use default large Staging Disk type request.</p>
        replicated_disks: <p>Update replication configuration replicated disks request.</p>
        ebs_encryption: <p>Update replication configuration EBS encryption request.</p>
        ebs_encryption_key_arn: <p>Update replication configuration EBS encryption key ARN request.</p>
        bandwidth_throttling: <p>Update replication configuration bandwidth throttling request.</p>
        data_plane_routing: <p>Update replication configuration data plane routing request.</p>
        create_public_ip: <p>Update replication configuration create Public IP request.</p>
        staging_area_tags: <p>Update replication configuration Staging Area Tags request.</p>
        use_fips_endpoint: <p>Update replication configuration use Fips Endpoint.</p>
        account_id: <p>Update replication configuration Account ID request.</p>
        internet_protocol: <p>Update replication configuration internet protocol.</p>
        store_snapshot_on_local_zone: <p>Update replication configuration store snapshot on local zone.</p>
        storage_configuration: <p>Update replication configuration storage configuration.</p>

    Raises:
        capo_mgn.errors.access_denied_exception.AccessDeniedException: <p>Operation denied due to a file permission or access check error.</p>
        capo_mgn.errors.conflict_exception.ConflictException: <p>The request could not be completed due to a conflict with the current state of the target resource.</p>
        capo_mgn.errors.resource_not_found_exception.ResourceNotFoundException: <p>Resource not found exception.</p>
        capo_mgn.errors.uninitialized_account_exception.UninitializedAccountException: <p>Uninitialized account exception.</p>
        capo_mgn.errors.validation_exception.ValidationException: <p>Validate exception.</p>
        capo_mgn.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_mgn.types.update_replication_configuration_request.UpdateReplicationConfigurationRequest]",
    ) -> AsyncOperationResponse[
        "capo_mgn.types.replication_configuration.ReplicationConfiguration"
    ]:
        import capo_mgn._operations.application_migration_service.update_replication_configuration

        (
            output,
            http_response,
        ) = await capo_mgn._operations.application_migration_service.update_replication_configuration.async_update_replication_configuration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_input(
        input_: "capo_mgn.types.update_replication_configuration_request.UpdateReplicationConfigurationRequest",
    ) -> dict[str, Any]:
        import capo_mgn.types.update_replication_configuration_request

        return capo_mgn.types.update_replication_configuration_request.redact_sensitive(
            input_
        )

    def _redact_output(
        output: "capo_mgn.types.replication_configuration.ReplicationConfiguration",
    ) -> dict[str, Any]:
        import capo_mgn.types.replication_configuration

        return capo_mgn.types.replication_configuration.redact_sensitive(output)

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging(
            "UpdateReplicationConfiguration",
            redact_input=_redact_input,
            redact_output=_redact_output,
        ),
    )
    input_: capo_mgn.types.update_replication_configuration_request.UpdateReplicationConfigurationRequest = {
        "source_server_id": source_server_id
    }
    if name is not None:
        input_["name"] = name
    if staging_area_subnet_id is not None:
        input_["staging_area_subnet_id"] = staging_area_subnet_id
    if associate_default_security_group is not None:
        input_["associate_default_security_group"] = (
            associate_default_security_group
        )
    if replication_servers_security_groups_i_ds is not None:
        input_["replication_servers_security_groups_i_ds"] = (
            replication_servers_security_groups_i_ds
        )
    if replication_server_instance_type is not None:
        input_["replication_server_instance_type"] = (
            replication_server_instance_type
        )
    if use_dedicated_replication_server is not None:
        input_["use_dedicated_replication_server"] = (
            use_dedicated_replication_server
        )
    if default_large_staging_disk_type is not None:
        input_["default_large_staging_disk_type"] = default_large_staging_disk_type
    if replicated_disks is not None:
        input_["replicated_disks"] = replicated_disks
    if ebs_encryption is not None:
        input_["ebs_encryption"] = ebs_encryption
    if ebs_encryption_key_arn is not None:
        input_["ebs_encryption_key_arn"] = ebs_encryption_key_arn
    if bandwidth_throttling is not None:
        input_["bandwidth_throttling"] = bandwidth_throttling
    if data_plane_routing is not None:
        input_["data_plane_routing"] = data_plane_routing
    if create_public_ip is not None:
        input_["create_public_ip"] = create_public_ip
    if staging_area_tags is not None:
        input_["staging_area_tags"] = staging_area_tags
    if use_fips_endpoint is not None:
        input_["use_fips_endpoint"] = use_fips_endpoint
    if account_id is not None:
        input_["account_id"] = account_id
    if internet_protocol is not None:
        input_["internet_protocol"] = internet_protocol
    if store_snapshot_on_local_zone is not None:
        input_["store_snapshot_on_local_zone"] = store_snapshot_on_local_zone
    if storage_configuration is not None:
        input_["storage_configuration"] = storage_configuration

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