Start the migration of data.
Parameters:
-
replication_group_id
(Optional[String], default:
None
)
–
The ID of the replication group to which data should be migrated.
-
customer_node_endpoint_list
(Optional[CustomerNodeEndpointList], default:
None
)
–
List of endpoints from which data should be migrated. For Valkey or Redis OSS (cluster mode disabled), the list should have only one element.
Raises:
Source code in docs_src/capo_elasticache/_services/elasti_cache.py
| def start_migration(
self,
*,
config_overrides: Optional[ElastiCacheClientConfig] = None,
replication_group_id: Optional["capo_elasticache.types.string.String"] = None,
customer_node_endpoint_list: Optional[
"capo_elasticache.types.customer_node_endpoint_list.CustomerNodeEndpointList"
] = None,
) -> "capo_elasticache.types.start_migration_response.StartMigrationResponse":
"""<p>Start the migration of data.</p>
Args:
replication_group_id: <p>The ID of the replication group to which data should be migrated.</p>
customer_node_endpoint_list: <p>List of endpoints from which data should be migrated. For Valkey or Redis OSS (cluster mode disabled), the list should have only one element.</p>
Raises:
capo_elasticache.errors.invalid_parameter_value_exception.InvalidParameterValueException: <p>The value for a parameter is invalid.</p>
capo_elasticache.errors.invalid_replication_group_state_fault.InvalidReplicationGroupStateFault: <p>The requested replication group is not in the <code>available</code> state.</p>
capo_elasticache.errors.replication_group_already_under_migration_fault.ReplicationGroupAlreadyUnderMigrationFault: <p>The targeted replication group is not available. </p>
capo_elasticache.errors.replication_group_not_found_fault.ReplicationGroupNotFoundFault: <p>The specified replication group does not exist.</p>
capo_elasticache.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
def _handler(
req: "OperationRequest[capo_elasticache.types.start_migration_message.StartMigrationMessage]",
) -> OperationResponse[
"capo_elasticache.types.start_migration_response.StartMigrationResponse"
]:
import capo_elasticache._operations.amazon_elasti_cache_v9.start_migration
output, http_response = (
capo_elasticache._operations.amazon_elasti_cache_v9.start_migration.start_migration(
req.options, req.input
)
)
return OperationResponse(output=output, response=http_response)
interceptors_, options_ = self.operation_options(
config_overrides, OperationLogging("StartMigration")
)
input_: capo_elasticache.types.start_migration_message.StartMigrationMessage = {}
if replication_group_id is not None:
input_["replication_group_id"] = replication_group_id
if customer_node_endpoint_list is not None:
input_["customer_node_endpoint_list"] = customer_node_endpoint_list
response = execute_pipeline(
OperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
response.response.close()
return response.output
|