create_replication_configuration_template async ¶

async def create_replication_configuration_template(
    self,
    staging_area_subnet_id: "capo_mgn.types.subnet_id.SubnetID",
    associate_default_security_group: bool,
    replication_servers_security_groups_i_ds: "capo_mgn.types.replication_servers_security_groups_i_ds.ReplicationServersSecurityGroupsIDs",
    replication_server_instance_type: "capo_mgn.types.ec2_instance_type.EC2InstanceType",
    use_dedicated_replication_server: bool,
    default_large_staging_disk_type: "capo_mgn.types.replication_configuration_default_large_staging_disk_type.ReplicationConfigurationDefaultLargeStagingDiskType",
    ebs_encryption: "capo_mgn.types.replication_configuration_ebs_encryption.ReplicationConfigurationEbsEncryption",
    bandwidth_throttling: "capo_mgn.types.bandwidth_throttling.BandwidthThrottling",
    data_plane_routing: "capo_mgn.types.replication_configuration_data_plane_routing.ReplicationConfigurationDataPlaneRouting",
    create_public_ip: bool,
    staging_area_tags: "capo_mgn.types.tags_map.TagsMap",
    *,
    config_overrides: Optional[AsyncmgnClientConfig] = None,
    ebs_encryption_key_arn: Optional["capo_mgn.types.arn.ARN"] = None,
    use_fips_endpoint: Optional[bool] = None,
    tags: Optional["capo_mgn.types.tags_map.TagsMap"] = 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_template.ReplicationConfigurationTemplate":
    """<p>Creates a new ReplicationConfigurationTemplate.</p>

    Args:
        staging_area_subnet_id: <p>Request to configure the Staging Area subnet ID during Replication Settings template creation.</p>
        associate_default_security_group: <p>Request to associate the default Application Migration Service Security group with the Replication Settings template.</p>
        replication_servers_security_groups_i_ds: <p>Request to configure the Replication Server Security group ID during Replication Settings template creation.</p>
        replication_server_instance_type: <p>Request to configure the Replication Server instance type during Replication Settings template creation.</p>
        use_dedicated_replication_server: <p>Request to use Dedicated Replication Servers during Replication Settings template creation.</p>
        default_large_staging_disk_type: <p>Request to configure the default large staging disk EBS volume type during Replication Settings template creation.</p>
        ebs_encryption: <p>Request to configure EBS encryption during Replication Settings template creation.</p>
        ebs_encryption_key_arn: <p>Request to configure an EBS encryption key during Replication Settings template creation.</p>
        bandwidth_throttling: <p>Request to configure bandwidth throttling during Replication Settings template creation.</p>
        data_plane_routing: <p>Request to configure data plane routing during Replication Settings template creation.</p>
        create_public_ip: <p>Request to create Public IP during Replication Settings template creation.</p>
        staging_area_tags: <p>Request to configure Staging Area tags during Replication Settings template creation.</p>
        use_fips_endpoint: <p>Request to use Fips Endpoint during Replication Settings template creation.</p>
        tags: <p>Request to configure tags during Replication Settings template creation.</p>
        internet_protocol: <p>Request to configure the internet protocol to IPv4 or IPv6.</p>
        store_snapshot_on_local_zone: <p>Request to store snapshot on local zone during Replication Settings template creation.</p>
        storage_configuration: <p>Request to configure storage during Replication Settings template creation.</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.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.create_replication_configuration_template_request.CreateReplicationConfigurationTemplateRequest]",
    ) -> AsyncOperationResponse[
        "capo_mgn.types.replication_configuration_template.ReplicationConfigurationTemplate"
    ]:
        import capo_mgn._operations.application_migration_service.create_replication_configuration_template

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

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

        return capo_mgn.types.create_replication_configuration_template_request.redact_sensitive(
            input_
        )

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

        return capo_mgn.types.replication_configuration_template.redact_sensitive(
            output
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging(
            "CreateReplicationConfigurationTemplate",
            redact_input=_redact_input,
            redact_output=_redact_output,
        ),
    )
    input_: capo_mgn.types.create_replication_configuration_template_request.CreateReplicationConfigurationTemplateRequest = {
        "staging_area_subnet_id": staging_area_subnet_id,
        "associate_default_security_group": associate_default_security_group,
        "replication_servers_security_groups_i_ds": replication_servers_security_groups_i_ds,
        "replication_server_instance_type": replication_server_instance_type,
        "use_dedicated_replication_server": use_dedicated_replication_server,
        "default_large_staging_disk_type": default_large_staging_disk_type,
        "ebs_encryption": ebs_encryption,
        "bandwidth_throttling": bandwidth_throttling,
        "data_plane_routing": data_plane_routing,
        "create_public_ip": create_public_ip,
        "staging_area_tags": staging_area_tags,
    }
    if ebs_encryption_key_arn is not None:
        input_["ebs_encryption_key_arn"] = ebs_encryption_key_arn
    if use_fips_endpoint is not None:
        input_["use_fips_endpoint"] = use_fips_endpoint
    if tags is not None:
        input_["tags"] = tags
    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