start_migration async ¶

async def start_migration(
    self,
    application_id: "capo_opensearch.types.application_id.ApplicationId",
    migration_options: "capo_opensearch.types.migration_options.MigrationOptions",
    *,
    config_overrides: Optional[AsyncOpenSearchClientConfig] = None,
    client_token: Optional["capo_opensearch.types.client_token.ClientToken"] = None,
) -> "capo_opensearch.types.start_migration_response.StartMigrationResponse":
    """<p>Initiates a migration job to migrate saved objects from a data source to an Amazon OpenSearch Service application workspace. Saved objects include dashboards, visualizations, index patterns, and searches. You can specify export filters to control the scope of the migration and a conflict resolution strategy for handling existing objects in the target workspace.</p>

    Args:
        application_id: <p>The unique identifier of the OpenSearch application to migrate saved objects into.</p>
        migration_options: <p>The configuration options for the migration, including the source data source, target workspace, export filters, and conflict resolution strategy.</p>
        client_token: <p>A unique, case-sensitive identifier to ensure that the operation completes no more than one time. If this token matches a previous request, Amazon OpenSearch Service ignores the request but does not return an error.</p>

    Raises:
        capo_opensearch.errors.access_denied_exception.AccessDeniedException: <p>An error occurred because you don't have permissions to access the resource.</p>
        capo_opensearch.errors.conflict_exception.ConflictException: <p>An error occurred because the client attempts to remove a resource that is currently in use.</p>
        capo_opensearch.errors.disabled_operation_exception.DisabledOperationException: <p>An error occured because the client wanted to access an unsupported operation.</p>
        capo_opensearch.errors.internal_exception.InternalException: <p>Request processing failed because of an unknown error, exception, or internal failure.</p>
        capo_opensearch.errors.resource_not_found_exception.ResourceNotFoundException: <p>An exception for accessing or deleting a resource that doesn't exist.</p>
        capo_opensearch.errors.validation_exception.ValidationException: <p>An exception for accessing or deleting a resource that doesn't exist.</p>
        capo_opensearch.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_opensearch.types.start_migration_request.StartMigrationRequest]",
    ) -> AsyncOperationResponse[
        "capo_opensearch.types.start_migration_response.StartMigrationResponse"
    ]:
        import capo_opensearch._operations.amazon_open_search_service.start_migration

        (
            output,
            http_response,
        ) = await capo_opensearch._operations.amazon_open_search_service.start_migration.async_start_migration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("StartMigration")
    )
    input_: capo_opensearch.types.start_migration_request.StartMigrationRequest = {
        "application_id": application_id,
        "migration_options": migration_options,
    }
    if client_token is not None:
        input_["client_token"] = client_token

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