in dts-20200101/alibabacloud_dts20200101/client.py [0:0]
def configure_dts_job_with_options(self, request, runtime):
"""
The name of the DTS instance.
@param request: ConfigureDtsJobRequest
@param runtime: runtime options for this request RuntimeOptions
@return: ConfigureDtsJobResponse
"""
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.checkpoint):
query['Checkpoint'] = request.checkpoint
if not UtilClient.is_unset(request.data_check_configure):
query['DataCheckConfigure'] = request.data_check_configure
if not UtilClient.is_unset(request.data_initialization):
query['DataInitialization'] = request.data_initialization
if not UtilClient.is_unset(request.data_synchronization):
query['DataSynchronization'] = request.data_synchronization
if not UtilClient.is_unset(request.dedicated_cluster_id):
query['DedicatedClusterId'] = request.dedicated_cluster_id
if not UtilClient.is_unset(request.delay_notice):
query['DelayNotice'] = request.delay_notice
if not UtilClient.is_unset(request.delay_phone):
query['DelayPhone'] = request.delay_phone
if not UtilClient.is_unset(request.delay_rule_time):
query['DelayRuleTime'] = request.delay_rule_time
if not UtilClient.is_unset(request.dest_ca_certificate_oss_url):
query['DestCaCertificateOssUrl'] = request.dest_ca_certificate_oss_url
if not UtilClient.is_unset(request.dest_ca_certificate_password):
query['DestCaCertificatePassword'] = request.dest_ca_certificate_password
if not UtilClient.is_unset(request.destination_endpoint_data_base_name):
query['DestinationEndpointDataBaseName'] = request.destination_endpoint_data_base_name
if not UtilClient.is_unset(request.destination_endpoint_engine_name):
query['DestinationEndpointEngineName'] = request.destination_endpoint_engine_name
if not UtilClient.is_unset(request.destination_endpoint_ip):
query['DestinationEndpointIP'] = request.destination_endpoint_ip
if not UtilClient.is_unset(request.destination_endpoint_instance_id):
query['DestinationEndpointInstanceID'] = request.destination_endpoint_instance_id
if not UtilClient.is_unset(request.destination_endpoint_instance_type):
query['DestinationEndpointInstanceType'] = request.destination_endpoint_instance_type
if not UtilClient.is_unset(request.destination_endpoint_oracle_sid):
query['DestinationEndpointOracleSID'] = request.destination_endpoint_oracle_sid
if not UtilClient.is_unset(request.destination_endpoint_owner_id):
query['DestinationEndpointOwnerID'] = request.destination_endpoint_owner_id
if not UtilClient.is_unset(request.destination_endpoint_password):
query['DestinationEndpointPassword'] = request.destination_endpoint_password
if not UtilClient.is_unset(request.destination_endpoint_port):
query['DestinationEndpointPort'] = request.destination_endpoint_port
if not UtilClient.is_unset(request.destination_endpoint_region):
query['DestinationEndpointRegion'] = request.destination_endpoint_region
if not UtilClient.is_unset(request.destination_endpoint_role):
query['DestinationEndpointRole'] = request.destination_endpoint_role
if not UtilClient.is_unset(request.destination_endpoint_user_name):
query['DestinationEndpointUserName'] = request.destination_endpoint_user_name
if not UtilClient.is_unset(request.disaster_recovery_job):
query['DisasterRecoveryJob'] = request.disaster_recovery_job
if not UtilClient.is_unset(request.dts_bis_label):
query['DtsBisLabel'] = request.dts_bis_label
if not UtilClient.is_unset(request.dts_instance_id):
query['DtsInstanceId'] = request.dts_instance_id
if not UtilClient.is_unset(request.dts_job_id):
query['DtsJobId'] = request.dts_job_id
if not UtilClient.is_unset(request.dts_job_name):
query['DtsJobName'] = request.dts_job_name
if not UtilClient.is_unset(request.error_notice):
query['ErrorNotice'] = request.error_notice
if not UtilClient.is_unset(request.error_phone):
query['ErrorPhone'] = request.error_phone
if not UtilClient.is_unset(request.file_oss_url):
query['FileOssUrl'] = request.file_oss_url
if not UtilClient.is_unset(request.job_type):
query['JobType'] = request.job_type
if not UtilClient.is_unset(request.max_du):
query['MaxDu'] = request.max_du
if not UtilClient.is_unset(request.min_du):
query['MinDu'] = request.min_du
if not UtilClient.is_unset(request.owner_id):
query['OwnerId'] = request.owner_id
if not UtilClient.is_unset(request.region_id):
query['RegionId'] = request.region_id
if not UtilClient.is_unset(request.resource_group_id):
query['ResourceGroupId'] = request.resource_group_id
if not UtilClient.is_unset(request.source_endpoint_database_name):
query['SourceEndpointDatabaseName'] = request.source_endpoint_database_name
if not UtilClient.is_unset(request.source_endpoint_engine_name):
query['SourceEndpointEngineName'] = request.source_endpoint_engine_name
if not UtilClient.is_unset(request.source_endpoint_ip):
query['SourceEndpointIP'] = request.source_endpoint_ip
if not UtilClient.is_unset(request.source_endpoint_instance_id):
query['SourceEndpointInstanceID'] = request.source_endpoint_instance_id
if not UtilClient.is_unset(request.source_endpoint_instance_type):
query['SourceEndpointInstanceType'] = request.source_endpoint_instance_type
if not UtilClient.is_unset(request.source_endpoint_oracle_sid):
query['SourceEndpointOracleSID'] = request.source_endpoint_oracle_sid
if not UtilClient.is_unset(request.source_endpoint_owner_id):
query['SourceEndpointOwnerID'] = request.source_endpoint_owner_id
if not UtilClient.is_unset(request.source_endpoint_password):
query['SourceEndpointPassword'] = request.source_endpoint_password
if not UtilClient.is_unset(request.source_endpoint_port):
query['SourceEndpointPort'] = request.source_endpoint_port
if not UtilClient.is_unset(request.source_endpoint_region):
query['SourceEndpointRegion'] = request.source_endpoint_region
if not UtilClient.is_unset(request.source_endpoint_role):
query['SourceEndpointRole'] = request.source_endpoint_role
if not UtilClient.is_unset(request.source_endpoint_user_name):
query['SourceEndpointUserName'] = request.source_endpoint_user_name
if not UtilClient.is_unset(request.source_endpoint_vswitch_id):
query['SourceEndpointVSwitchID'] = request.source_endpoint_vswitch_id
if not UtilClient.is_unset(request.src_ca_certificate_oss_url):
query['SrcCaCertificateOssUrl'] = request.src_ca_certificate_oss_url
if not UtilClient.is_unset(request.src_ca_certificate_password):
query['SrcCaCertificatePassword'] = request.src_ca_certificate_password
if not UtilClient.is_unset(request.structure_initialization):
query['StructureInitialization'] = request.structure_initialization
if not UtilClient.is_unset(request.synchronization_direction):
query['SynchronizationDirection'] = request.synchronization_direction
body = {}
if not UtilClient.is_unset(request.db_list):
body['DbList'] = request.db_list
if not UtilClient.is_unset(request.reserve):
body['Reserve'] = request.reserve
req = open_api_models.OpenApiRequest(
query=OpenApiUtilClient.query(query),
body=OpenApiUtilClient.parse_to_map(body)
)
params = open_api_models.Params(
action='ConfigureDtsJob',
version='2020-01-01',
protocol='HTTPS',
pathname='/',
method='POST',
auth_type='AK',
style='RPC',
req_body_type='formData',
body_type='json'
)
return TeaCore.from_map(
dts_20200101_models.ConfigureDtsJobResponse(),
self.call_api(params, req, runtime)
)