&dZddlmZddlmZddlmZddlmZddlmZddlmZddl m Z dd l m Z dd l m Zdd lmZd Zd j%e ddZdj%e ddZGddeZe j.e j0j2Gddee j4Ze j.e j0j8Gddee j4Zy)z:Command to create migration jobs for a database migration.)absolute_import)division)unicode_literals)api_util)migration_jobs) resource_args)base)flags)logzMhttps://cloud.google.com/database-migration/docs/mysql/configure-connectivityaE Create a Database Migration Service migration job. Recommended steps before creating the migration job: - Create a source connection profile. See prerequisites [here](https://cloud.google.com/database-migration/docs/mysql/configure-source-database). - Create a destination connection profile. For migrating to Cloud SQL for MySQL or Cloud SQL for PostgreSQL, use the cloudsql connection profile for DMS to create the CloudSQL replica for you. - Configure the connectivity method. See prerequisites [here]({MYSQL_CONNECTIVITY_DOC}). )MYSQL_CONNECTIVITY_DOCa To create a continuous migration job with IP allowlist connectivity: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 To create a continuous migration job with VPC peering connectivity: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 --peer-vpc=projects/my-project/global/networks/my-network To create a one-time migration job with reverse-SSH tunnel connectivity: $ {command} my-migration-job --region=us-central1 --type=ONE_TIME --source=cp1 --destination=cp2 --vm=vm1 --vm-ip=1.1.1.1 --vm-port=1111 --vpc=projects/my-project/global/networks/my-network ) DESCRIPTIONEXAMPLESa Create a Database Migration Service migration job. Recommended steps before creating the migration job: - Create a source connection profile. See prerequisites [here](https://cloud.google.com/database-migration/docs/mysql/configure-source-database). - Create a destination connection profile. For migrating to Cloud SQL for MySQL or Cloud SQL for PostgreSQL, use the cloudsql connection profile for DMS to create the CloudSQL replica for you. - Configure the connectivity method. See prerequisites [here]({MYSQL_CONNECTIVITY_DOC}). - [Heterogeneous migrations only] Create a conversion workspace. a To create a continuous migration job with IP allowlist connectivity: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 To create a continuous migration job with VPC peering connectivity: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 --peer-vpc=projects/my-project/global/networks/my-network To create a one-time migration job with reverse-SSH tunnel connectivity: $ {command} my-migration-job --region=us-central1 --type=ONE_TIME --source=cp1 --destination=cp2 --vm=vm1 --vm-ip=1.1.1.1 --vm-port=1111 --vpc=projects/my-project/global/networks/my-network To create a heterogeneous continuous migration job: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 --conversion-workspace=cw To create a continuous SQL Server to SQL Server homogeneous migration job with differential backup enabled: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 --sqlserver-diff-backup --sqlserver-databases=db1,db2,db3 To create a continuous SQL Server to SQL Server homogeneous migration job with encrypted databases: $ {command} my-migration-job --region=us-central1 --type=CONTINUOUS --source=cp1 --destination=cp2 --sqlserver-databases=db1,db2,db3 --sqlserver-encrypted-databases=PATH/TO/ENCRYPTION/SETTINGS c&eZdZdZedZdZy)_Create2Create a Database Migration Service migration job.c:tj|tj|tj|dtj|tj |tj jdtj|y)Args is called by calliope to gather arguments for this command. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. TrequiredN) mj_flagsAddNoAsyncFlagAddDisplayNameFlag AddTypeFlagAddDumpGroupFlagAddConnectivityGroupFlagApiTypeCREATEr AddLabelsCreateFlagsparsers 7lib/surface/database_migration/migration_jobs/create.pyArgsz _Create.Argsoso F# ' $/ f% %%  ''$ v&c |jjj}|jj }|jj j}|jj j}|jtjjk(rI|jjj}|jjj}nd}d}tj|j}|j||j|||||} t!j"|j} t!j$|j} t!j&|j} |j)drt*j,j/dj1|j| j2t!j4| | | j6t*j,j/dj1|j| j2y| jd| j2|j8|j:} | j<j?| jA| jBS)a'Create a Database Migration Service migration job. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: A dict object representing the operations resource describing the create operation if the create was successful. Nno_asyncz6Waiting for migration job [{}] to be created with [{}]zCreated migration job {} [{}]z+datamigration.projects.locations.operations) operationsId projectsId locationsId)name)"CONCEPTS migration_jobParseParent RelativeNamesource destination ReleaseTrackr GAconversion_workspacecmek_keyrMigrationJobsClientCreatemigrationJobsIdrGetClientInstanceGetMessagesModuleGetResourceParserIsKnownAndSpecifiedr statusPrintformatr) HandleLRO projects_locations_migrationJobsr'r(projects_locations_operationsGet2DatamigrationProjectsLocationsOperationsGetRequestr&)selfargsmigration_job_ref parent_ref source_refdestination_refconversion_workspace_ref cmek_key_ref mj_clientresult_operationclientmessagesresource_parser operation_refs r!Runz _Create.RunsT 3399;"))+88:J%%++-Jmm//557O d//222!%!C!C!I!I!K]]++113l!%l2243D3D3FGI ''))   ' '(9(9(; H001B1B1DEO  + jj B I I//1A1F1F HI!1@@B jj6==  + +-=-B-BDE #**5%**$//%11 +3M  / / 3 3CC++ D - ..r#N)__name__ __module__ __qualname____doc__ staticmethodr"rRr#r!rrls:'' :.r#rc$eZdZdZeZedZy)CreateGArctj|ddtj|t j |t j |t j|t j|dt j|t j|t j|y)r to createTrF) is_updateN) r(AddHeterogeneousMigrationJobResourceArgsrr"r AddFilterFlagAddCommitIdFlagAddDumpParallelLevelFlag*AddSqlServerHomogeneousMigrationConfigFlagAddDumpTypeFlag2AddMigrationJobObjectsConfigFlagForCreateAndUpdate#AddHeterogeneousMigrationConfigFlagrs r!r"z CreateGA.Argss:: d LL 6" V$ %%f- 77%P V$ ??G 008r#N)rSrTrUrVDETAILED_HELP_GA detailed_helprWr"rXr#r!rZrZs:"-99r#rZc$eZdZdZeZedZy) CreateAlpharc^tj|ddtj|y)rr\TrN)rAddMigrationJobResourceArgsrr"rs r!r"zCreateAlpha.Argss'-- d LLr#N)rSrTrUrVDETAILED_HELP_ALPHArgrWr"rXr#r!riris:%-  r#riN)rV __future__rrr)googlecloudsdk.api_lib.database_migrationrrrgooglecloudsdk.callioper -googlecloudsdk.command_lib.database_migrationr rlrfobjectr ReleaseTracksr1r2CommandrZALPHArirXr#r!rwsA&'>DC(?Z#h F*@F A :  F*@F A$ .bN.fN.bD%%(()9w 9*94D%%++,'4<<-r#