dms-enterprise-20181101/alibabacloud_dms_enterprise20181101/client.py

# -*- coding: utf-8 -*- # This file is auto-generated, don't edit it. Thanks. from __future__ import unicode_literals from Tea.core import TeaCore from alibabacloud_tea_openapi.client import Client as OpenApiClient from alibabacloud_tea_openapi import models as open_api_models from alibabacloud_tea_util.client import Client as UtilClient from alibabacloud_endpoint_util.client import Client as EndpointUtilClient from alibabacloud_dms_enterprise20181101 import models as dms_enterprise_20181101_models from alibabacloud_tea_util import models as util_models from alibabacloud_openapi_util.client import Client as OpenApiUtilClient class Client(OpenApiClient): """ *\ """ def __init__(self, config): super(Client, self).__init__(config) self._endpoint_rule = 'central' self.check_config(config) self._endpoint = self.get_endpoint('dms-enterprise', self._region_id, self._endpoint_rule, self._network, self._suffix, self._endpoint_map, self._endpoint) def get_endpoint(self, product_id, region_id, endpoint_rule, network, suffix, endpoint_map, endpoint): if not UtilClient.empty(endpoint): return endpoint if not UtilClient.is_unset(endpoint_map) and not UtilClient.empty(endpoint_map.get(region_id)): return endpoint_map.get(region_id) return EndpointUtilClient.get_endpoint_rules(product_id, region_id, endpoint_rule, network, suffix) def add_desensitization_rule_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.function_type): query['FunctionType'] = request.function_type if not UtilClient.is_unset(request.rule_description): query['RuleDescription'] = request.rule_description if not UtilClient.is_unset(request.rule_name): query['RuleName'] = request.rule_name if not UtilClient.is_unset(request.rule_type): query['RuleType'] = request.rule_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid body = {} body_flat = {} if not UtilClient.is_unset(request.function_params): body_flat['FunctionParams'] = request.function_params body = TeaCore.merge(body, OpenApiUtilClient.query(body_flat)) req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query), body=OpenApiUtilClient.parse_to_map(body) ) params = open_api_models.Params( action='AddDesensitizationRule', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AddDesensitizationRuleResponse(), self.call_api(params, req, runtime) ) def add_desensitization_rule(self, request): runtime = util_models.RuntimeOptions() return self.add_desensitization_rule_with_options(request, runtime) def add_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.data_link_name): query['DataLinkName'] = request.data_link_name if not UtilClient.is_unset(request.database_password): query['DatabasePassword'] = request.database_password if not UtilClient.is_unset(request.database_user): query['DatabaseUser'] = request.database_user if not UtilClient.is_unset(request.dba_id): query['DbaId'] = request.dba_id if not UtilClient.is_unset(request.ddl_online): query['DdlOnline'] = request.ddl_online if not UtilClient.is_unset(request.ecs_instance_id): query['EcsInstanceId'] = request.ecs_instance_id if not UtilClient.is_unset(request.ecs_region): query['EcsRegion'] = request.ecs_region if not UtilClient.is_unset(request.enable_sell_common): query['EnableSellCommon'] = request.enable_sell_common if not UtilClient.is_unset(request.enable_sell_sitd): query['EnableSellSitd'] = request.enable_sell_sitd if not UtilClient.is_unset(request.enable_sell_stable): query['EnableSellStable'] = request.enable_sell_stable if not UtilClient.is_unset(request.enable_sell_trust): query['EnableSellTrust'] = request.enable_sell_trust if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.export_timeout): query['ExportTimeout'] = request.export_timeout if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.instance_alias): query['InstanceAlias'] = request.instance_alias if not UtilClient.is_unset(request.instance_source): query['InstanceSource'] = request.instance_source if not UtilClient.is_unset(request.instance_type): query['InstanceType'] = request.instance_type if not UtilClient.is_unset(request.network_type): query['NetworkType'] = request.network_type if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.query_timeout): query['QueryTimeout'] = request.query_timeout if not UtilClient.is_unset(request.safe_rule): query['SafeRule'] = request.safe_rule if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.skip_test): query['SkipTest'] = request.skip_test if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.template_type): query['TemplateType'] = request.template_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.use_dsql): query['UseDsql'] = request.use_dsql if not UtilClient.is_unset(request.use_ssl): query['UseSsl'] = request.use_ssl if not UtilClient.is_unset(request.vpc_id): query['VpcId'] = request.vpc_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='AddInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AddInstanceResponse(), self.call_api(params, req, runtime) ) def add_instance(self, request): runtime = util_models.RuntimeOptions() return self.add_instance_with_options(request, runtime) def add_lh_members_with_options(self, tmp_req, runtime): """ You must call this operation as a DMS administrator, a database administrator (DBA), or a workspace administrator. Usage notes: * Before you call this operation to add a user as a task flow developer, make sure that you have added the user as a workspace member. * You cannot call this operation to transfer the ownership of a task flow. To transfer the ownership of a task flow, call the [ChangLhDagOwner](~~424761~~) operation. * For more information about workspace roles and permissions, see [Manage permissions on a workspace](~~410893~~). @param tmp_req: AddLhMembersRequest @param runtime: runtime options for this request RuntimeOptions @return: AddLhMembersResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.AddLhMembersShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.members): request.members_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.members, 'Members', 'json') query = {} if not UtilClient.is_unset(request.members_shrink): query['Members'] = request.members_shrink if not UtilClient.is_unset(request.object_id): query['ObjectId'] = request.object_id if not UtilClient.is_unset(request.object_type): query['ObjectType'] = request.object_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='AddLhMembers', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AddLhMembersResponse(), self.call_api(params, req, runtime) ) def add_lh_members(self, request): """ You must call this operation as a DMS administrator, a database administrator (DBA), or a workspace administrator. Usage notes: * Before you call this operation to add a user as a task flow developer, make sure that you have added the user as a workspace member. * You cannot call this operation to transfer the ownership of a task flow. To transfer the ownership of a task flow, call the [ChangLhDagOwner](~~424761~~) operation. * For more information about workspace roles and permissions, see [Manage permissions on a workspace](~~410893~~). @param request: AddLhMembersRequest @return: AddLhMembersResponse """ runtime = util_models.RuntimeOptions() return self.add_lh_members_with_options(request, runtime) def add_logic_table_route_config_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.route_expr): query['RouteExpr'] = request.route_expr if not UtilClient.is_unset(request.route_key): query['RouteKey'] = request.route_key if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='AddLogicTableRouteConfig', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AddLogicTableRouteConfigResponse(), self.call_api(params, req, runtime) ) def add_logic_table_route_config(self, request): runtime = util_models.RuntimeOptions() return self.add_logic_table_route_config_with_options(request, runtime) def add_task_flow_edges_with_options(self, tmp_req, runtime): """ When you add directed edges for a task node, take note of the following limits: 1. The endpoints of the specified edge exist in the Directed Acyclic Graph (DAG) of the task flow specified by DagId. 2. After a backward edge is added, the DAG does not contain loops. @param tmp_req: AddTaskFlowEdgesRequest @param runtime: runtime options for this request RuntimeOptions @return: AddTaskFlowEdgesResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.AddTaskFlowEdgesShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.edges): request.edges_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.edges, 'Edges', 'json') query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.edges_shrink): query['Edges'] = request.edges_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='AddTaskFlowEdges', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AddTaskFlowEdgesResponse(), self.call_api(params, req, runtime) ) def add_task_flow_edges(self, request): """ When you add directed edges for a task node, take note of the following limits: 1. The endpoints of the specified edge exist in the Directed Acyclic Graph (DAG) of the task flow specified by DagId. 2. After a backward edge is added, the DAG does not contain loops. @param request: AddTaskFlowEdgesRequest @return: AddTaskFlowEdgesResponse """ runtime = util_models.RuntimeOptions() return self.add_task_flow_edges_with_options(request, runtime) def analyze_sqllineage_with_options(self, request, runtime): """ The following conditions must be met before you call this API operation. * The database instance is of one of the following types: ApsaraDB RDS for MySQL, PolarDB for MySQL, AnalyticDB for MySQL, ApsaraDB RDS for PostgreSQL, PolarDB for PostgreSQL, AnalyticDB for PostgreSQL, Oracle, and openGauss. * A database instance is managed in Security Collaboration mode. For more information about control modes, see [Control modes](~~151629~~). @param request: AnalyzeSQLLineageRequest @param runtime: runtime options for this request RuntimeOptions @return: AnalyzeSQLLineageResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.sql_content): query['SqlContent'] = request.sql_content if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='AnalyzeSQLLineage', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.AnalyzeSQLLineageResponse(), self.call_api(params, req, runtime) ) def analyze_sqllineage(self, request): """ The following conditions must be met before you call this API operation. * The database instance is of one of the following types: ApsaraDB RDS for MySQL, PolarDB for MySQL, AnalyticDB for MySQL, ApsaraDB RDS for PostgreSQL, PolarDB for PostgreSQL, AnalyticDB for PostgreSQL, Oracle, and openGauss. * A database instance is managed in Security Collaboration mode. For more information about control modes, see [Control modes](~~151629~~). @param request: AnalyzeSQLLineageRequest @return: AnalyzeSQLLineageResponse """ runtime = util_models.RuntimeOptions() return self.analyze_sqllineage_with_options(request, runtime) def approve_order_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.approval_node_id): query['ApprovalNodeId'] = request.approval_node_id if not UtilClient.is_unset(request.approval_node_pos): query['ApprovalNodePos'] = request.approval_node_pos if not UtilClient.is_unset(request.approval_type): query['ApprovalType'] = request.approval_type if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.new_approver): query['NewApprover'] = request.new_approver if not UtilClient.is_unset(request.new_approver_list): query['NewApproverList'] = request.new_approver_list if not UtilClient.is_unset(request.old_approver): query['OldApprover'] = request.old_approver if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.workflow_instance_id): query['WorkflowInstanceId'] = request.workflow_instance_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ApproveOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ApproveOrderResponse(), self.call_api(params, req, runtime) ) def approve_order(self, request): runtime = util_models.RuntimeOptions() return self.approve_order_with_options(request, runtime) def back_fill_with_options(self, tmp_req, runtime): """ During a data backfill, task flows are run in sequence based on their dates. You can specify whether task flows are run in chronological or reverse chronological order. After the data backfill is complete, you can specify a date or date range, and a node range to run task flows. @param tmp_req: BackFillRequest @param runtime: runtime options for this request RuntimeOptions @return: BackFillResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.BackFillShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.filter_node_ids): request.filter_node_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.filter_node_ids, 'FilterNodeIds', 'json') if not UtilClient.is_unset(tmp_req.start_node_ids): request.start_node_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.start_node_ids, 'StartNodeIds', 'json') query = {} if not UtilClient.is_unset(request.asc): query['Asc'] = request.asc if not UtilClient.is_unset(request.back_fill_date): query['BackFillDate'] = request.back_fill_date if not UtilClient.is_unset(request.back_fill_date_begin): query['BackFillDateBegin'] = request.back_fill_date_begin if not UtilClient.is_unset(request.back_fill_date_end): query['BackFillDateEnd'] = request.back_fill_date_end if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.filter_node_ids_shrink): query['FilterNodeIds'] = request.filter_node_ids_shrink if not UtilClient.is_unset(request.history_dag_id): query['HistoryDagId'] = request.history_dag_id if not UtilClient.is_unset(request.interval): query['Interval'] = request.interval if not UtilClient.is_unset(request.is_trigger_sub_tree): query['IsTriggerSubTree'] = request.is_trigger_sub_tree if not UtilClient.is_unset(request.start_node_ids_shrink): query['StartNodeIds'] = request.start_node_ids_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='BackFill', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.BackFillResponse(), self.call_api(params, req, runtime) ) def back_fill(self, request): """ During a data backfill, task flows are run in sequence based on their dates. You can specify whether task flows are run in chronological or reverse chronological order. After the data backfill is complete, you can specify a date or date range, and a node range to run task flows. @param request: BackFillRequest @return: BackFillResponse """ runtime = util_models.RuntimeOptions() return self.back_fill_with_options(request, runtime) def buy_pay_as_you_go_order_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.commodity_type): query['CommodityType'] = request.commodity_type if not UtilClient.is_unset(request.ins_num): query['InsNum'] = request.ins_num if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.version_type): query['VersionType'] = request.version_type req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='BuyPayAsYouGoOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.BuyPayAsYouGoOrderResponse(), self.call_api(params, req, runtime) ) def buy_pay_as_you_go_order(self, request): runtime = util_models.RuntimeOptions() return self.buy_pay_as_you_go_order_with_options(request, runtime) def change_column_sec_level_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.is_logic): query['IsLogic'] = request.is_logic if not UtilClient.is_unset(request.new_level): query['NewLevel'] = request.new_level if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ChangeColumnSecLevel', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ChangeColumnSecLevelResponse(), self.call_api(params, req, runtime) ) def change_column_sec_level(self, request): runtime = util_models.RuntimeOptions() return self.change_column_sec_level_with_options(request, runtime) def change_column_security_level_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.is_logic): query['IsLogic'] = request.is_logic if not UtilClient.is_unset(request.new_sensitivity_level): query['NewSensitivityLevel'] = request.new_sensitivity_level if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ChangeColumnSecurityLevel', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ChangeColumnSecurityLevelResponse(), self.call_api(params, req, runtime) ) def change_column_security_level(self, request): runtime = util_models.RuntimeOptions() return self.change_column_security_level_with_options(request, runtime) def change_lh_dag_owner_with_options(self, request, runtime): """ Usage notes: * If you call this operation to transfer the ownership of a published task flow, the ownership transfer does not take effect. * You can call the [ReDeployLhDagVersion](~~424712~~) operation to redeploy a published version of a task flow. @param request: ChangeLhDagOwnerRequest @param runtime: runtime options for this request RuntimeOptions @return: ChangeLhDagOwnerResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.owner_user_id): query['OwnerUserId'] = request.owner_user_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ChangeLhDagOwner', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ChangeLhDagOwnerResponse(), self.call_api(params, req, runtime) ) def change_lh_dag_owner(self, request): """ Usage notes: * If you call this operation to transfer the ownership of a published task flow, the ownership transfer does not take effect. * You can call the [ReDeployLhDagVersion](~~424712~~) operation to redeploy a published version of a task flow. @param request: ChangeLhDagOwnerRequest @return: ChangeLhDagOwnerResponse """ runtime = util_models.RuntimeOptions() return self.change_lh_dag_owner_with_options(request, runtime) def close_order_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.close_reason): query['CloseReason'] = request.close_reason if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CloseOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CloseOrderResponse(), self.call_api(params, req, runtime) ) def close_order(self, request): runtime = util_models.RuntimeOptions() return self.close_order_with_options(request, runtime) def create_authority_template_with_options(self, request, runtime): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: CreateAuthorityTemplateRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateAuthorityTemplateResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.name): query['Name'] = request.name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateAuthorityTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateAuthorityTemplateResponse(), self.call_api(params, req, runtime) ) def create_authority_template(self, request): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: CreateAuthorityTemplateRequest @return: CreateAuthorityTemplateResponse """ runtime = util_models.RuntimeOptions() return self.create_authority_template_with_options(request, runtime) def create_data_archive_order_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataArchiveOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.parent_id): query['ParentId'] = request.parent_id if not UtilClient.is_unset(request.plugin_type): query['PluginType'] = request.plugin_type if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataArchiveOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataArchiveOrderResponse(), self.call_api(params, req, runtime) ) def create_data_archive_order(self, request): runtime = util_models.RuntimeOptions() return self.create_data_archive_order_with_options(request, runtime) def create_data_correct_order_with_options(self, tmp_req, runtime): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param tmp_req: CreateDataCorrectOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateDataCorrectOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataCorrectOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataCorrectOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataCorrectOrderResponse(), self.call_api(params, req, runtime) ) def create_data_correct_order(self, request): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param request: CreateDataCorrectOrderRequest @return: CreateDataCorrectOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_data_correct_order_with_options(request, runtime) def create_data_cron_clear_order_with_options(self, tmp_req, runtime): """ For more information about the historical data cleaning, see [Clear historical data](~~162507~~). This operation can be used only for MySQL databases. @param tmp_req: CreateDataCronClearOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateDataCronClearOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataCronClearOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataCronClearOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataCronClearOrderResponse(), self.call_api(params, req, runtime) ) def create_data_cron_clear_order(self, request): """ For more information about the historical data cleaning, see [Clear historical data](~~162507~~). This operation can be used only for MySQL databases. @param request: CreateDataCronClearOrderRequest @return: CreateDataCronClearOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_data_cron_clear_order_with_options(request, runtime) def create_data_export_order_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataExportOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.plugin_param): request.plugin_param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.plugin_param, 'PluginParam', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.parent_id): query['ParentId'] = request.parent_id if not UtilClient.is_unset(request.plugin_param_shrink): query['PluginParam'] = request.plugin_param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataExportOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataExportOrderResponse(), self.call_api(params, req, runtime) ) def create_data_export_order(self, request): runtime = util_models.RuntimeOptions() return self.create_data_export_order_with_options(request, runtime) def create_data_import_order_with_options(self, tmp_req, runtime): """ For more information about the Large Data Import feature, see [Import data](~~161439~~). @param tmp_req: CreateDataImportOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateDataImportOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataImportOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataImportOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataImportOrderResponse(), self.call_api(params, req, runtime) ) def create_data_import_order(self, request): """ For more information about the Large Data Import feature, see [Import data](~~161439~~). @param request: CreateDataImportOrderRequest @return: CreateDataImportOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_data_import_order_with_options(request, runtime) def create_data_track_order_with_options(self, tmp_req, runtime): """ This operation is available only for instances that are managed in Security Collaboration mode. @param tmp_req: CreateDataTrackOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateDataTrackOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDataTrackOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDataTrackOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDataTrackOrderResponse(), self.call_api(params, req, runtime) ) def create_data_track_order(self, request): """ This operation is available only for instances that are managed in Security Collaboration mode. @param request: CreateDataTrackOrderRequest @return: CreateDataTrackOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_data_track_order_with_options(request, runtime) def create_database_export_order_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateDatabaseExportOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.plugin_param): request.plugin_param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.plugin_param, 'PluginParam', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.parent_id): query['ParentId'] = request.parent_id if not UtilClient.is_unset(request.plugin_param_shrink): query['PluginParam'] = request.plugin_param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateDatabaseExportOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateDatabaseExportOrderResponse(), self.call_api(params, req, runtime) ) def create_database_export_order(self, request): runtime = util_models.RuntimeOptions() return self.create_database_export_order_with_options(request, runtime) def create_free_lock_correct_order_with_options(self, tmp_req, runtime): """ For more information about the lock-free change feature, see [Overview](~~207847~~). This operation can be used only for instances that are managed in Stable Change or Security Collaboration mode. For more information, see [Change data without the need to lock tables](~~96145~~) and [Change schemas without locking tables](~~98373~~). @param tmp_req: CreateFreeLockCorrectOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateFreeLockCorrectOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateFreeLockCorrectOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateFreeLockCorrectOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateFreeLockCorrectOrderResponse(), self.call_api(params, req, runtime) ) def create_free_lock_correct_order(self, request): """ For more information about the lock-free change feature, see [Overview](~~207847~~). This operation can be used only for instances that are managed in Stable Change or Security Collaboration mode. For more information, see [Change data without the need to lock tables](~~96145~~) and [Change schemas without locking tables](~~98373~~). @param request: CreateFreeLockCorrectOrderRequest @return: CreateFreeLockCorrectOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_free_lock_correct_order_with_options(request, runtime) def create_lake_house_space_with_options(self, request, runtime): """ The workspace name must be unique within a tenant. If a workspace with the same name already exists within the tenant, the call may fail. * You can call the [GetLhSpaceByName](~~424379~~) operation to query whether a workspace with a specific name already exists as a DMS administrator or database administrator (DBA). @param request: CreateLakeHouseSpaceRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateLakeHouseSpaceResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.dev_db_id): query['DevDbId'] = request.dev_db_id if not UtilClient.is_unset(request.dw_db_type): query['DwDbType'] = request.dw_db_type if not UtilClient.is_unset(request.mode): query['Mode'] = request.mode if not UtilClient.is_unset(request.prod_db_id): query['ProdDbId'] = request.prod_db_id if not UtilClient.is_unset(request.space_config): query['SpaceConfig'] = request.space_config if not UtilClient.is_unset(request.space_name): query['SpaceName'] = request.space_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateLakeHouseSpace', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateLakeHouseSpaceResponse(), self.call_api(params, req, runtime) ) def create_lake_house_space(self, request): """ The workspace name must be unique within a tenant. If a workspace with the same name already exists within the tenant, the call may fail. * You can call the [GetLhSpaceByName](~~424379~~) operation to query whether a workspace with a specific name already exists as a DMS administrator or database administrator (DBA). @param request: CreateLakeHouseSpaceRequest @return: CreateLakeHouseSpaceResponse """ runtime = util_models.RuntimeOptions() return self.create_lake_house_space_with_options(request, runtime) def create_logic_database_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateLogicDatabaseShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.database_ids): request.database_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.database_ids, 'DatabaseIds', 'json') query = {} if not UtilClient.is_unset(request.alias): query['Alias'] = request.alias if not UtilClient.is_unset(request.database_ids_shrink): query['DatabaseIds'] = request.database_ids_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateLogicDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateLogicDatabaseResponse(), self.call_api(params, req, runtime) ) def create_logic_database(self, request): runtime = util_models.RuntimeOptions() return self.create_logic_database_with_options(request, runtime) def create_order_with_options(self, tmp_req, runtime): """ To facilitate ticket creation, you can call the following dedicated operations to create some types of tickets: * [CreateDataCorrectOrder](~~208388~~): creates a regular data change ticket. * [CreateDataCronClearOrder](~~208385~~): creates a ticket to clear historical data. * [CreateDataImportOrder](~~208387~~): creates a data import ticket. * [CreateFreeLockCorrectOrder](~~208386~~): creates a lock-free change ticket. @param tmp_req: CreateOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.plugin_param): request.plugin_param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.plugin_param, 'PluginParam', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.plugin_type): query['PluginType'] = request.plugin_type if not UtilClient.is_unset(request.related_user_list): query['RelatedUserList'] = request.related_user_list if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid body = {} if not UtilClient.is_unset(request.plugin_param_shrink): body['PluginParam'] = request.plugin_param_shrink req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query), body=OpenApiUtilClient.parse_to_map(body) ) params = open_api_models.Params( action='CreateOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateOrderResponse(), self.call_api(params, req, runtime) ) def create_order(self, request): """ To facilitate ticket creation, you can call the following dedicated operations to create some types of tickets: * [CreateDataCorrectOrder](~~208388~~): creates a regular data change ticket. * [CreateDataCronClearOrder](~~208385~~): creates a ticket to clear historical data. * [CreateDataImportOrder](~~208387~~): creates a data import ticket. * [CreateFreeLockCorrectOrder](~~208386~~): creates a lock-free change ticket. @param request: CreateOrderRequest @return: CreateOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_order_with_options(request, runtime) def create_proc_correct_order_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateProcCorrectOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateProcCorrectOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateProcCorrectOrderResponse(), self.call_api(params, req, runtime) ) def create_proc_correct_order(self, request): runtime = util_models.RuntimeOptions() return self.create_proc_correct_order_with_options(request, runtime) def create_proxy_with_options(self, request, runtime): """ - The database instance runs the MySQL or MariaDB database engine. For example, the database instance can be an ApsaraDB RDS for MySQL instance, a PolarDB for MySQL cluster, a Distributed Relational Database Service (DRDS) cluster, or an AnalyticDB for MySQL cluster. The database instance can also be a self-managed MySQL or MariaDB database, or a MySQL or MariaDB database in a third-party cloud. - The database instance resides in the China (Hangzhou) or China (Beijing) region. - You are a Data Management (DMS) administrator, a database administrator (DBA), or the owner of the database instance. @param request: CreateProxyRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateProxyResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.password): query['Password'] = request.password if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.username): query['Username'] = request.username req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateProxy', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateProxyResponse(), self.call_api(params, req, runtime) ) def create_proxy(self, request): """ - The database instance runs the MySQL or MariaDB database engine. For example, the database instance can be an ApsaraDB RDS for MySQL instance, a PolarDB for MySQL cluster, a Distributed Relational Database Service (DRDS) cluster, or an AnalyticDB for MySQL cluster. The database instance can also be a self-managed MySQL or MariaDB database, or a MySQL or MariaDB database in a third-party cloud. - The database instance resides in the China (Hangzhou) or China (Beijing) region. - You are a Data Management (DMS) administrator, a database administrator (DBA), or the owner of the database instance. @param request: CreateProxyRequest @return: CreateProxyResponse """ runtime = util_models.RuntimeOptions() return self.create_proxy_with_options(request, runtime) def create_proxy_access_with_options(self, request, runtime): """ - The data security protection feature is enabled for the instance. - Your user role is the administrator role, DBA role, or the owner of data security protection for the current instance. @param request: CreateProxyAccessRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateProxyAccessResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.indep_account): query['IndepAccount'] = request.indep_account if not UtilClient.is_unset(request.indep_password): query['IndepPassword'] = request.indep_password if not UtilClient.is_unset(request.proxy_id): query['ProxyId'] = request.proxy_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateProxyAccess', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateProxyAccessResponse(), self.call_api(params, req, runtime) ) def create_proxy_access(self, request): """ - The data security protection feature is enabled for the instance. - Your user role is the administrator role, DBA role, or the owner of data security protection for the current instance. @param request: CreateProxyAccessRequest @return: CreateProxyAccessResponse """ runtime = util_models.RuntimeOptions() return self.create_proxy_access_with_options(request, runtime) def create_publish_group_task_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.plan_time): query['PlanTime'] = request.plan_time if not UtilClient.is_unset(request.publish_strategy): query['PublishStrategy'] = request.publish_strategy if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreatePublishGroupTask', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreatePublishGroupTaskResponse(), self.call_api(params, req, runtime) ) def create_publish_group_task(self, request): runtime = util_models.RuntimeOptions() return self.create_publish_group_task_with_options(request, runtime) def create_sqlreview_order_with_options(self, tmp_req, runtime): """ You can call this operation only for database instances that are managed in Security Collaboration mode. For more information about the SQL review feature, see [SQL review](~~60374~~). @param tmp_req: CreateSQLReviewOrderRequest @param runtime: runtime options for this request RuntimeOptions @return: CreateSQLReviewOrderResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateSQLReviewOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateSQLReviewOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateSQLReviewOrderResponse(), self.call_api(params, req, runtime) ) def create_sqlreview_order(self, request): """ You can call this operation only for database instances that are managed in Security Collaboration mode. For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: CreateSQLReviewOrderRequest @return: CreateSQLReviewOrderResponse """ runtime = util_models.RuntimeOptions() return self.create_sqlreview_order_with_options(request, runtime) def create_scenario_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.scenario_name): query['ScenarioName'] = request.scenario_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateScenario', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateScenarioResponse(), self.call_api(params, req, runtime) ) def create_scenario(self, request): runtime = util_models.RuntimeOptions() return self.create_scenario_with_options(request, runtime) def create_standard_group_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_type): query['DbType'] = request.db_type if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.group_name): query['GroupName'] = request.group_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateStandardGroup', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateStandardGroupResponse(), self.call_api(params, req, runtime) ) def create_standard_group(self, request): runtime = util_models.RuntimeOptions() return self.create_standard_group_with_options(request, runtime) def create_struct_sync_order_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateStructSyncOrderShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.param): request.param_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.param, 'Param', 'json') if not UtilClient.is_unset(tmp_req.related_user_list): request.related_user_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.related_user_list, 'RelatedUserList', 'json') query = {} if not UtilClient.is_unset(request.attachment_key): query['AttachmentKey'] = request.attachment_key if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.param_shrink): query['Param'] = request.param_shrink if not UtilClient.is_unset(request.related_user_list_shrink): query['RelatedUserList'] = request.related_user_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateStructSyncOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateStructSyncOrderResponse(), self.call_api(params, req, runtime) ) def create_struct_sync_order(self, request): runtime = util_models.RuntimeOptions() return self.create_struct_sync_order_with_options(request, runtime) def create_task_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.graph_param): query['GraphParam'] = request.graph_param if not UtilClient.is_unset(request.node_content): query['NodeContent'] = request.node_content if not UtilClient.is_unset(request.node_name): query['NodeName'] = request.node_name if not UtilClient.is_unset(request.node_output): query['NodeOutput'] = request.node_output if not UtilClient.is_unset(request.node_type): query['NodeType'] = request.node_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.time_variables): query['TimeVariables'] = request.time_variables req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateTask', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateTaskResponse(), self.call_api(params, req, runtime) ) def create_task(self, request): runtime = util_models.RuntimeOptions() return self.create_task_with_options(request, runtime) def create_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_name): query['DagName'] = request.dag_name if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.scenario_id): query['ScenarioId'] = request.scenario_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateTaskFlowResponse(), self.call_api(params, req, runtime) ) def create_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.create_task_flow_with_options(request, runtime) def create_upload_file_job_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.file_name): query['FileName'] = request.file_name if not UtilClient.is_unset(request.file_source): query['FileSource'] = request.file_source if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.upload_url): query['UploadURL'] = request.upload_url req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateUploadFileJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateUploadFileJobResponse(), self.call_api(params, req, runtime) ) def create_upload_file_job(self, request): runtime = util_models.RuntimeOptions() return self.create_upload_file_job_with_options(request, runtime) def create_upload_ossfile_job_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.CreateUploadOSSFileJobShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.upload_target): request.upload_target_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.upload_target, 'UploadTarget', 'json') query = {} if not UtilClient.is_unset(request.file_name): query['FileName'] = request.file_name if not UtilClient.is_unset(request.file_source): query['FileSource'] = request.file_source if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.upload_target_shrink): query['UploadTarget'] = request.upload_target_shrink req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='CreateUploadOSSFileJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.CreateUploadOSSFileJobResponse(), self.call_api(params, req, runtime) ) def create_upload_ossfile_job(self, request): runtime = util_models.RuntimeOptions() return self.create_upload_ossfile_job_with_options(request, runtime) def delete_authority_template_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteAuthorityTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteAuthorityTemplateResponse(), self.call_api(params, req, runtime) ) def delete_authority_template(self, request): runtime = util_models.RuntimeOptions() return self.delete_authority_template_with_options(request, runtime) def delete_instance_with_options(self, request, runtime): """ Note: You can call this operation only to remove a database instance from the instance list of DMS. The instance is not deleted or shut down. @param request: DeleteInstanceRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteInstanceResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteInstanceResponse(), self.call_api(params, req, runtime) ) def delete_instance(self, request): """ Note: You can call this operation only to remove a database instance from the instance list of DMS. The instance is not deleted or shut down. @param request: DeleteInstanceRequest @return: DeleteInstanceResponse """ runtime = util_models.RuntimeOptions() return self.delete_instance_with_options(request, runtime) def delete_lake_house_space_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.space_id): query['SpaceId'] = request.space_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteLakeHouseSpace', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteLakeHouseSpaceResponse(), self.call_api(params, req, runtime) ) def delete_lake_house_space(self, request): runtime = util_models.RuntimeOptions() return self.delete_lake_house_space_with_options(request, runtime) def delete_lh_members_with_options(self, tmp_req, runtime): """ You must call this operation as a DMS administrator, a database administrator (DBA), or a workspace administrator. You cannot call this operation to transfer the ownership of a task flow. To transfer the ownership of a task flow, call the [ChangLhDagOwner](~~424761~~) operation. @param tmp_req: DeleteLhMembersRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteLhMembersResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.DeleteLhMembersShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.member_ids): request.member_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.member_ids, 'MemberIds', 'json') query = {} if not UtilClient.is_unset(request.member_ids_shrink): query['MemberIds'] = request.member_ids_shrink if not UtilClient.is_unset(request.object_id): query['ObjectId'] = request.object_id if not UtilClient.is_unset(request.object_type): query['ObjectType'] = request.object_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteLhMembers', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteLhMembersResponse(), self.call_api(params, req, runtime) ) def delete_lh_members(self, request): """ You must call this operation as a DMS administrator, a database administrator (DBA), or a workspace administrator. You cannot call this operation to transfer the ownership of a task flow. To transfer the ownership of a task flow, call the [ChangLhDagOwner](~~424761~~) operation. @param request: DeleteLhMembersRequest @return: DeleteLhMembersResponse """ runtime = util_models.RuntimeOptions() return self.delete_lh_members_with_options(request, runtime) def delete_logic_database_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.logic_db_id): query['LogicDbId'] = request.logic_db_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteLogicDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteLogicDatabaseResponse(), self.call_api(params, req, runtime) ) def delete_logic_database(self, request): runtime = util_models.RuntimeOptions() return self.delete_logic_database_with_options(request, runtime) def delete_logic_table_route_config_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.route_key): query['RouteKey'] = request.route_key if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteLogicTableRouteConfig', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteLogicTableRouteConfigResponse(), self.call_api(params, req, runtime) ) def delete_logic_table_route_config(self, request): runtime = util_models.RuntimeOptions() return self.delete_logic_table_route_config_with_options(request, runtime) def delete_proxy_with_options(self, request, runtime): """ After you disable this feature, your DB instance loses the JDBC protocol. All authorization information is recycled. @param request: DeleteProxyRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteProxyResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_id): query['ProxyId'] = request.proxy_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteProxy', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteProxyResponse(), self.call_api(params, req, runtime) ) def delete_proxy(self, request): """ After you disable this feature, your DB instance loses the JDBC protocol. All authorization information is recycled. @param request: DeleteProxyRequest @return: DeleteProxyResponse """ runtime = util_models.RuntimeOptions() return self.delete_proxy_with_options(request, runtime) def delete_proxy_access_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_access_id): query['ProxyAccessId'] = request.proxy_access_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteProxyAccess', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteProxyAccessResponse(), self.call_api(params, req, runtime) ) def delete_proxy_access(self, request): runtime = util_models.RuntimeOptions() return self.delete_proxy_access_with_options(request, runtime) def delete_scenario_with_options(self, request, runtime): """ When you call this operation, make sure that no task flow is specified in the business scenario. @param request: DeleteScenarioRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteScenarioResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.scenario_id): query['ScenarioId'] = request.scenario_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteScenario', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteScenarioResponse(), self.call_api(params, req, runtime) ) def delete_scenario(self, request): """ When you call this operation, make sure that no task flow is specified in the business scenario. @param request: DeleteScenarioRequest @return: DeleteScenarioResponse """ runtime = util_models.RuntimeOptions() return self.delete_scenario_with_options(request, runtime) def delete_standard_group_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.group_id): query['GroupId'] = request.group_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteStandardGroup', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteStandardGroupResponse(), self.call_api(params, req, runtime) ) def delete_standard_group(self, request): runtime = util_models.RuntimeOptions() return self.delete_standard_group_with_options(request, runtime) def delete_task_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteTask', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteTaskResponse(), self.call_api(params, req, runtime) ) def delete_task(self, request): runtime = util_models.RuntimeOptions() return self.delete_task_with_options(request, runtime) def delete_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteTaskFlowResponse(), self.call_api(params, req, runtime) ) def delete_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.delete_task_flow_with_options(request, runtime) def delete_task_flow_edges_by_condition_with_options(self, request, runtime): """ This operation is used for multi-condition query. You can call it to delete the edges of a specified task flow that meet all specified conditions. @param request: DeleteTaskFlowEdgesByConditionRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteTaskFlowEdgesByConditionResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.id): query['Id'] = request.id if not UtilClient.is_unset(request.node_end): query['NodeEnd'] = request.node_end if not UtilClient.is_unset(request.node_from): query['NodeFrom'] = request.node_from if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteTaskFlowEdgesByCondition', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteTaskFlowEdgesByConditionResponse(), self.call_api(params, req, runtime) ) def delete_task_flow_edges_by_condition(self, request): """ This operation is used for multi-condition query. You can call it to delete the edges of a specified task flow that meet all specified conditions. @param request: DeleteTaskFlowEdgesByConditionRequest @return: DeleteTaskFlowEdgesByConditionResponse """ runtime = util_models.RuntimeOptions() return self.delete_task_flow_edges_by_condition_with_options(request, runtime) def delete_user_with_options(self, request, runtime): """ The effect of deleting a user by calling this operation is the same as that of deleting a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to delete a user that is no longer used from DMS Enterprise. After the user is deleted, the data source permission, data owner configuration, and database administrator (DBA) configuration of the corresponding Alibaba Cloud account or Resource Access Management (RAM) user are revoked and become invalid. > This operation only removes the association of the Alibaba Cloud account or RAM user with DMS Enterprise of the enterprise, rather than actually deleting the Alibaba Cloud account or RAM user. After the user is deleted, the Alibaba Cloud account or RAM user cannot log on to DMS Enterprise, unless the user is added to DMS Enterprise again. @param request: DeleteUserRequest @param runtime: runtime options for this request RuntimeOptions @return: DeleteUserResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DeleteUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DeleteUserResponse(), self.call_api(params, req, runtime) ) def delete_user(self, request): """ The effect of deleting a user by calling this operation is the same as that of deleting a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to delete a user that is no longer used from DMS Enterprise. After the user is deleted, the data source permission, data owner configuration, and database administrator (DBA) configuration of the corresponding Alibaba Cloud account or Resource Access Management (RAM) user are revoked and become invalid. > This operation only removes the association of the Alibaba Cloud account or RAM user with DMS Enterprise of the enterprise, rather than actually deleting the Alibaba Cloud account or RAM user. After the user is deleted, the Alibaba Cloud account or RAM user cannot log on to DMS Enterprise, unless the user is added to DMS Enterprise again. @param request: DeleteUserRequest @return: DeleteUserResponse """ runtime = util_models.RuntimeOptions() return self.delete_user_with_options(request, runtime) def disable_user_with_options(self, request, runtime): """ The effect of disabling a user by calling this operation is the same as that of disabling a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to disable a user that is temporarily not used in DMS Enterprise. After the user is disabled, the data source permission, data owner configuration, and database administrator (DBA) configuration of the corresponding Alibaba Cloud account or Resource Access Management (RAM) user are revoked and become invalid. > This operation only stops the Alibaba Cloud account or RAM user from logging on to DMS Enterprise of the enterprise, rather than actually disabling the Alibaba Cloud account or RAM user. After the user is disabled, the Alibaba Cloud account or RAM user cannot log on to DMS Enterprise, unless the user is enabled again. The disabled user, however, still exists in DMS Enterprise. @param request: DisableUserRequest @param runtime: runtime options for this request RuntimeOptions @return: DisableUserResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DisableUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DisableUserResponse(), self.call_api(params, req, runtime) ) def disable_user(self, request): """ The effect of disabling a user by calling this operation is the same as that of disabling a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to disable a user that is temporarily not used in DMS Enterprise. After the user is disabled, the data source permission, data owner configuration, and database administrator (DBA) configuration of the corresponding Alibaba Cloud account or Resource Access Management (RAM) user are revoked and become invalid. > This operation only stops the Alibaba Cloud account or RAM user from logging on to DMS Enterprise of the enterprise, rather than actually disabling the Alibaba Cloud account or RAM user. After the user is disabled, the Alibaba Cloud account or RAM user cannot log on to DMS Enterprise, unless the user is enabled again. The disabled user, however, still exists in DMS Enterprise. @param request: DisableUserRequest @return: DisableUserResponse """ runtime = util_models.RuntimeOptions() return self.disable_user_with_options(request, runtime) def download_data_track_result_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.DownloadDataTrackResultShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.column_filter): request.column_filter_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.column_filter, 'ColumnFilter', 'json') if not UtilClient.is_unset(tmp_req.event_id_list): request.event_id_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.event_id_list, 'EventIdList', 'json') if not UtilClient.is_unset(tmp_req.filter_table_list): request.filter_table_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.filter_table_list, 'FilterTableList', 'json') if not UtilClient.is_unset(tmp_req.filter_type_list): request.filter_type_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.filter_type_list, 'FilterTypeList', 'json') query = {} if not UtilClient.is_unset(request.column_filter_shrink): query['ColumnFilter'] = request.column_filter_shrink if not UtilClient.is_unset(request.event_id_list_shrink): query['EventIdList'] = request.event_id_list_shrink if not UtilClient.is_unset(request.filter_end_time): query['FilterEndTime'] = request.filter_end_time if not UtilClient.is_unset(request.filter_start_time): query['FilterStartTime'] = request.filter_start_time if not UtilClient.is_unset(request.filter_table_list_shrink): query['FilterTableList'] = request.filter_table_list_shrink if not UtilClient.is_unset(request.filter_type_list_shrink): query['FilterTypeList'] = request.filter_type_list_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.rollback_sqltype): query['RollbackSQLType'] = request.rollback_sqltype if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='DownloadDataTrackResult', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.DownloadDataTrackResultResponse(), self.call_api(params, req, runtime) ) def download_data_track_result(self, request): runtime = util_models.RuntimeOptions() return self.download_data_track_result_with_options(request, runtime) def edit_logic_database_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.EditLogicDatabaseShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.database_ids): request.database_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.database_ids, 'DatabaseIds', 'json') query = {} if not UtilClient.is_unset(request.alias): query['Alias'] = request.alias if not UtilClient.is_unset(request.database_ids_shrink): query['DatabaseIds'] = request.database_ids_shrink if not UtilClient.is_unset(request.logic_db_id): query['LogicDbId'] = request.logic_db_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='EditLogicDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.EditLogicDatabaseResponse(), self.call_api(params, req, runtime) ) def edit_logic_database(self, request): runtime = util_models.RuntimeOptions() return self.edit_logic_database_with_options(request, runtime) def enable_user_with_options(self, request, runtime): """ The effect of enabling a user by calling this operation is the same as that of enabling a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to enable a user that has been disabled in DMS Enterprise. After the user is enabled, the corresponding Alibaba Cloud account or Resource Access Management (RAM) user can continue to log on to DMS Enterprise and perform relevant operations. > This operation only enables the Alibaba Cloud account or RAM user to log on to DMS Enterprise of the enterprise and perform relevant operations, rather than granting other permissions to the Alibaba Cloud account or RAM user. @param request: EnableUserRequest @param runtime: runtime options for this request RuntimeOptions @return: EnableUserResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='EnableUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.EnableUserResponse(), self.call_api(params, req, runtime) ) def enable_user(self, request): """ The effect of enabling a user by calling this operation is the same as that of enabling a user by choosing System Management > User Management in the DMS Enterprise console. The administrator of DMS Enterprise can call this operation to enable a user that has been disabled in DMS Enterprise. After the user is enabled, the corresponding Alibaba Cloud account or Resource Access Management (RAM) user can continue to log on to DMS Enterprise and perform relevant operations. > This operation only enables the Alibaba Cloud account or RAM user to log on to DMS Enterprise of the enterprise and perform relevant operations, rather than granting other permissions to the Alibaba Cloud account or RAM user. @param request: EnableUserRequest @return: EnableUserResponse """ runtime = util_models.RuntimeOptions() return self.enable_user_with_options(request, runtime) def execute_data_correct_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.ExecuteDataCorrectShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.action_detail): request.action_detail_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.action_detail, 'ActionDetail', 'json') query = {} if not UtilClient.is_unset(request.action_detail_shrink): query['ActionDetail'] = request.action_detail_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ExecuteDataCorrect', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ExecuteDataCorrectResponse(), self.call_api(params, req, runtime) ) def execute_data_correct(self, request): runtime = util_models.RuntimeOptions() return self.execute_data_correct_with_options(request, runtime) def execute_data_export_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.ExecuteDataExportShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.action_detail): request.action_detail_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.action_detail, 'ActionDetail', 'json') query = {} if not UtilClient.is_unset(request.action_detail_shrink): query['ActionDetail'] = request.action_detail_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ExecuteDataExport', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ExecuteDataExportResponse(), self.call_api(params, req, runtime) ) def execute_data_export(self, request): runtime = util_models.RuntimeOptions() return self.execute_data_export_with_options(request, runtime) def execute_script_with_options(self, request, runtime): """ You can call this operation only for instances that are managed in Security Collaboration mode. @param request: ExecuteScriptRequest @param runtime: runtime options for this request RuntimeOptions @return: ExecuteScriptResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.script): query['Script'] = request.script if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ExecuteScript', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ExecuteScriptResponse(), self.call_api(params, req, runtime) ) def execute_script(self, request): """ You can call this operation only for instances that are managed in Security Collaboration mode. @param request: ExecuteScriptRequest @return: ExecuteScriptResponse """ runtime = util_models.RuntimeOptions() return self.execute_script_with_options(request, runtime) def execute_struct_sync_with_options(self, request, runtime): """ If the security rules of an instance indicate that a ticket must be approved before you perform schema synchronization, you can call the [SubmitStructSyncOrderApproval](~~206166~~) operation to submit the ticket for approval. > You can call the [GetStructSyncJobDetail](~~206160~~) operation to query whether you need to submit a ticket for approval. @param request: ExecuteStructSyncRequest @param runtime: runtime options for this request RuntimeOptions @return: ExecuteStructSyncResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ExecuteStructSync', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ExecuteStructSyncResponse(), self.call_api(params, req, runtime) ) def execute_struct_sync(self, request): """ If the security rules of an instance indicate that a ticket must be approved before you perform schema synchronization, you can call the [SubmitStructSyncOrderApproval](~~206166~~) operation to submit the ticket for approval. > You can call the [GetStructSyncJobDetail](~~206160~~) operation to query whether you need to submit a ticket for approval. @param request: ExecuteStructSyncRequest @return: ExecuteStructSyncResponse """ runtime = util_models.RuntimeOptions() return self.execute_struct_sync_with_options(request, runtime) def get_approval_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.workflow_instance_id): query['WorkflowInstanceId'] = request.workflow_instance_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetApprovalDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetApprovalDetailResponse(), self.call_api(params, req, runtime) ) def get_approval_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_approval_detail_with_options(request, runtime) def get_authority_template_with_options(self, request, runtime): """ You must be a Data Management (DMS) administrator or a database administrator (DBA). For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GetAuthorityTemplateRequest @param runtime: runtime options for this request RuntimeOptions @return: GetAuthorityTemplateResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetAuthorityTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetAuthorityTemplateResponse(), self.call_api(params, req, runtime) ) def get_authority_template(self, request): """ You must be a Data Management (DMS) administrator or a database administrator (DBA). For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GetAuthorityTemplateRequest @return: GetAuthorityTemplateResponse """ runtime = util_models.RuntimeOptions() return self.get_authority_template_with_options(request, runtime) def get_authority_template_item_with_options(self, request, runtime): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GetAuthorityTemplateItemRequest @param runtime: runtime options for this request RuntimeOptions @return: GetAuthorityTemplateItemResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetAuthorityTemplateItem', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetAuthorityTemplateItemResponse(), self.call_api(params, req, runtime) ) def get_authority_template_item(self, request): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GetAuthorityTemplateItemRequest @return: GetAuthorityTemplateItemResponse """ runtime = util_models.RuntimeOptions() return self.get_authority_template_item_with_options(request, runtime) def get_classification_template_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetClassificationTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetClassificationTemplateResponse(), self.call_api(params, req, runtime) ) def get_classification_template(self, request): runtime = util_models.RuntimeOptions() return self.get_classification_template_with_options(request, runtime) def get_dbtask_sqljob_log_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_id): query['JobId'] = request.job_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDBTaskSQLJobLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDBTaskSQLJobLogResponse(), self.call_api(params, req, runtime) ) def get_dbtask_sqljob_log(self, request): runtime = util_models.RuntimeOptions() return self.get_dbtask_sqljob_log_with_options(request, runtime) def get_dbtopology_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.logic_db_id): query['LogicDbId'] = request.logic_db_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDBTopology', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDBTopologyResponse(), self.call_api(params, req, runtime) ) def get_dbtopology(self, request): runtime = util_models.RuntimeOptions() return self.get_dbtopology_with_options(request, runtime) def get_data_archive_count_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_result_type): query['OrderResultType'] = request.order_result_type if not UtilClient.is_unset(request.plugin_type): query['PluginType'] = request.plugin_type if not UtilClient.is_unset(request.search_date_type): query['SearchDateType'] = request.search_date_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataArchiveCount', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataArchiveCountResponse(), self.call_api(params, req, runtime) ) def get_data_archive_count(self, request): runtime = util_models.RuntimeOptions() return self.get_data_archive_count_with_options(request, runtime) def get_data_archive_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataArchiveOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataArchiveOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_data_archive_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_archive_order_detail_with_options(request, runtime) def get_data_correct_backup_files_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.GetDataCorrectBackupFilesShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.action_detail): request.action_detail_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.action_detail, 'ActionDetail', 'json') query = {} if not UtilClient.is_unset(request.action_detail_shrink): query['ActionDetail'] = request.action_detail_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCorrectBackupFiles', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCorrectBackupFilesResponse(), self.call_api(params, req, runtime) ) def get_data_correct_backup_files(self, request): runtime = util_models.RuntimeOptions() return self.get_data_correct_backup_files_with_options(request, runtime) def get_data_correct_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCorrectOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCorrectOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_data_correct_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_correct_order_detail_with_options(request, runtime) def get_data_correct_rollback_file_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCorrectRollbackFile', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCorrectRollbackFileResponse(), self.call_api(params, req, runtime) ) def get_data_correct_rollback_file(self, request): runtime = util_models.RuntimeOptions() return self.get_data_correct_rollback_file_with_options(request, runtime) def get_data_correct_sqlfile_with_options(self, request, runtime): """ This operation applies to [regular data change](~~58419~~) and [batch data import](~~144643~~). @param request: GetDataCorrectSQLFileRequest @param runtime: runtime options for this request RuntimeOptions @return: GetDataCorrectSQLFileResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCorrectSQLFile', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCorrectSQLFileResponse(), self.call_api(params, req, runtime) ) def get_data_correct_sqlfile(self, request): """ This operation applies to [regular data change](~~58419~~) and [batch data import](~~144643~~). @param request: GetDataCorrectSQLFileRequest @return: GetDataCorrectSQLFileResponse """ runtime = util_models.RuntimeOptions() return self.get_data_correct_sqlfile_with_options(request, runtime) def get_data_correct_task_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCorrectTaskDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCorrectTaskDetailResponse(), self.call_api(params, req, runtime) ) def get_data_correct_task_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_correct_task_detail_with_options(request, runtime) def get_data_cron_clear_config_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCronClearConfig', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCronClearConfigResponse(), self.call_api(params, req, runtime) ) def get_data_cron_clear_config(self, request): runtime = util_models.RuntimeOptions() return self.get_data_cron_clear_config_with_options(request, runtime) def get_data_cron_clear_task_detail_list_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataCronClearTaskDetailList', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataCronClearTaskDetailListResponse(), self.call_api(params, req, runtime) ) def get_data_cron_clear_task_detail_list(self, request): runtime = util_models.RuntimeOptions() return self.get_data_cron_clear_task_detail_list_with_options(request, runtime) def get_data_export_download_urlwith_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataExportDownloadURL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataExportDownloadURLResponse(), self.call_api(params, req, runtime) ) def get_data_export_download_url(self, request): runtime = util_models.RuntimeOptions() return self.get_data_export_download_urlwith_options(request, runtime) def get_data_export_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid body = {} if not UtilClient.is_unset(request.order_id): body['OrderId'] = request.order_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query), body=OpenApiUtilClient.parse_to_map(body) ) params = open_api_models.Params( action='GetDataExportOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataExportOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_data_export_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_export_order_detail_with_options(request, runtime) def get_data_export_pre_check_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataExportPreCheckDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataExportPreCheckDetailResponse(), self.call_api(params, req, runtime) ) def get_data_export_pre_check_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_export_pre_check_detail_with_options(request, runtime) def get_data_import_sqlwith_options(self, request, runtime): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: GetDataImportSQLRequest @param runtime: runtime options for this request RuntimeOptions @return: GetDataImportSQLResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.sql_id): query['SqlId'] = request.sql_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataImportSQL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataImportSQLResponse(), self.call_api(params, req, runtime) ) def get_data_import_sql(self, request): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: GetDataImportSQLRequest @return: GetDataImportSQLResponse """ runtime = util_models.RuntimeOptions() return self.get_data_import_sqlwith_options(request, runtime) def get_data_track_job_degree_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataTrackJobDegree', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataTrackJobDegreeResponse(), self.call_api(params, req, runtime) ) def get_data_track_job_degree(self, request): runtime = util_models.RuntimeOptions() return self.get_data_track_job_degree_with_options(request, runtime) def get_data_track_job_table_meta_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataTrackJobTableMeta', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataTrackJobTableMetaResponse(), self.call_api(params, req, runtime) ) def get_data_track_job_table_meta(self, request): runtime = util_models.RuntimeOptions() return self.get_data_track_job_table_meta_with_options(request, runtime) def get_data_track_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDataTrackOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDataTrackOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_data_track_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_data_track_order_detail_with_options(request, runtime) def get_database_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDatabaseResponse(), self.call_api(params, req, runtime) ) def get_database(self, request): runtime = util_models.RuntimeOptions() return self.get_database_with_options(request, runtime) def get_database_export_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid body = {} if not UtilClient.is_unset(request.order_id): body['OrderId'] = request.order_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query), body=OpenApiUtilClient.parse_to_map(body) ) params = open_api_models.Params( action='GetDatabaseExportOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDatabaseExportOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_database_export_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_database_export_order_detail_with_options(request, runtime) def get_db_export_download_urlwith_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetDbExportDownloadURL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetDbExportDownloadURLResponse(), self.call_api(params, req, runtime) ) def get_db_export_download_url(self, request): runtime = util_models.RuntimeOptions() return self.get_db_export_download_urlwith_options(request, runtime) def get_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetInstanceResponse(), self.call_api(params, req, runtime) ) def get_instance(self, request): runtime = util_models.RuntimeOptions() return self.get_instance_with_options(request, runtime) def get_interval_limit_of_slawith_options(self, request, runtime): """ The scheduling cycle of a task flow must be greater than the minimum scheduling cycle configured in the SLA rule for the task flow. @param request: GetIntervalLimitOfSLARequest @param runtime: runtime options for this request RuntimeOptions @return: GetIntervalLimitOfSLAResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetIntervalLimitOfSLA', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetIntervalLimitOfSLAResponse(), self.call_api(params, req, runtime) ) def get_interval_limit_of_sla(self, request): """ The scheduling cycle of a task flow must be greater than the minimum scheduling cycle configured in the SLA rule for the task flow. @param request: GetIntervalLimitOfSLARequest @return: GetIntervalLimitOfSLAResponse """ runtime = util_models.RuntimeOptions() return self.get_interval_limit_of_slawith_options(request, runtime) def get_lh_space_by_name_with_options(self, request, runtime): """ You are a DMS administrator or a database administrator (DBA). @param request: GetLhSpaceByNameRequest @param runtime: runtime options for this request RuntimeOptions @return: GetLhSpaceByNameResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.space_name): query['SpaceName'] = request.space_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetLhSpaceByName', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetLhSpaceByNameResponse(), self.call_api(params, req, runtime) ) def get_lh_space_by_name(self, request): """ You are a DMS administrator or a database administrator (DBA). @param request: GetLhSpaceByNameRequest @return: GetLhSpaceByNameResponse """ runtime = util_models.RuntimeOptions() return self.get_lh_space_by_name_with_options(request, runtime) def get_logic_database_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetLogicDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetLogicDatabaseResponse(), self.call_api(params, req, runtime) ) def get_logic_database(self, request): runtime = util_models.RuntimeOptions() return self.get_logic_database_with_options(request, runtime) def get_meta_table_column_with_options(self, request, runtime): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: GetMetaTableColumnRequest @param runtime: runtime options for this request RuntimeOptions @return: GetMetaTableColumnResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.table_guid): query['TableGuid'] = request.table_guid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetMetaTableColumn', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetMetaTableColumnResponse(), self.call_api(params, req, runtime) ) def get_meta_table_column(self, request): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: GetMetaTableColumnRequest @return: GetMetaTableColumnResponse """ runtime = util_models.RuntimeOptions() return self.get_meta_table_column_with_options(request, runtime) def get_meta_table_detail_info_with_options(self, request, runtime): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: GetMetaTableDetailInfoRequest @param runtime: runtime options for this request RuntimeOptions @return: GetMetaTableDetailInfoResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.table_guid): query['TableGuid'] = request.table_guid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetMetaTableDetailInfo', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetMetaTableDetailInfoResponse(), self.call_api(params, req, runtime) ) def get_meta_table_detail_info(self, request): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: GetMetaTableDetailInfoRequest @return: GetMetaTableDetailInfoResponse """ runtime = util_models.RuntimeOptions() return self.get_meta_table_detail_info_with_options(request, runtime) def get_online_ddlprogress_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_detail_id): query['JobDetailId'] = request.job_detail_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetOnlineDDLProgress', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetOnlineDDLProgressResponse(), self.call_api(params, req, runtime) ) def get_online_ddlprogress(self, request): runtime = util_models.RuntimeOptions() return self.get_online_ddlprogress_with_options(request, runtime) def get_op_log_with_options(self, request, runtime): """ Prerequisites: You are an administrator of Data Management (DMS) or a security administrator. You can call the [ListUsers](~~141938~~) or [GetUser](~~147098~~) operation to obtain your user role from the RoleIdList parameter that is returned. @param request: GetOpLogRequest @param runtime: runtime options for this request RuntimeOptions @return: GetOpLogResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.database_name): query['DatabaseName'] = request.database_name if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.module): query['Module'] = request.module if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_nick): query['UserNick'] = request.user_nick req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetOpLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetOpLogResponse(), self.call_api(params, req, runtime) ) def get_op_log(self, request): """ Prerequisites: You are an administrator of Data Management (DMS) or a security administrator. You can call the [ListUsers](~~141938~~) or [GetUser](~~147098~~) operation to obtain your user role from the RoleIdList parameter that is returned. @param request: GetOpLogRequest @return: GetOpLogResponse """ runtime = util_models.RuntimeOptions() return self.get_op_log_with_options(request, runtime) def get_order_attachment_file_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetOrderAttachmentFile', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetOrderAttachmentFileResponse(), self.call_api(params, req, runtime) ) def get_order_attachment_file(self, request): runtime = util_models.RuntimeOptions() return self.get_order_attachment_file_with_options(request, runtime) def get_order_base_info_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetOrderBaseInfo', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetOrderBaseInfoResponse(), self.call_api(params, req, runtime) ) def get_order_base_info(self, request): runtime = util_models.RuntimeOptions() return self.get_order_base_info_with_options(request, runtime) def get_owner_apply_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetOwnerApplyOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetOwnerApplyOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_owner_apply_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_owner_apply_order_detail_with_options(request, runtime) def get_paged_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = OpenApiUtilClient.query(UtilClient.to_map(request)) req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetPagedInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='GET', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetPagedInstanceResponse(), self.call_api(params, req, runtime) ) def get_paged_instance(self, request): runtime = util_models.RuntimeOptions() return self.get_paged_instance_with_options(request, runtime) def get_perm_apply_order_detail_with_options(self, request, runtime): """ You can call this operation to query the information about tickets that apply for permissions on databases, tables, and sensitive columns. @param request: GetPermApplyOrderDetailRequest @param runtime: runtime options for this request RuntimeOptions @return: GetPermApplyOrderDetailResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetPermApplyOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetPermApplyOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_perm_apply_order_detail(self, request): """ You can call this operation to query the information about tickets that apply for permissions on databases, tables, and sensitive columns. @param request: GetPermApplyOrderDetailRequest @return: GetPermApplyOrderDetailResponse """ runtime = util_models.RuntimeOptions() return self.get_perm_apply_order_detail_with_options(request, runtime) def get_physical_database_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetPhysicalDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetPhysicalDatabaseResponse(), self.call_api(params, req, runtime) ) def get_physical_database(self, request): runtime = util_models.RuntimeOptions() return self.get_physical_database_with_options(request, runtime) def get_proxy_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_id): query['ProxyId'] = request.proxy_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetProxy', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetProxyResponse(), self.call_api(params, req, runtime) ) def get_proxy(self, request): runtime = util_models.RuntimeOptions() return self.get_proxy_with_options(request, runtime) def get_proxy_access_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_access_id): query['ProxyAccessId'] = request.proxy_access_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetProxyAccess', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetProxyAccessResponse(), self.call_api(params, req, runtime) ) def get_proxy_access(self, request): runtime = util_models.RuntimeOptions() return self.get_proxy_access_with_options(request, runtime) def get_rule_num_limit_of_slawith_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetRuleNumLimitOfSLA', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetRuleNumLimitOfSLAResponse(), self.call_api(params, req, runtime) ) def get_rule_num_limit_of_sla(self, request): runtime = util_models.RuntimeOptions() return self.get_rule_num_limit_of_slawith_options(request, runtime) def get_sqlreview_check_result_status_with_options(self, request, runtime): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: GetSQLReviewCheckResultStatusRequest @param runtime: runtime options for this request RuntimeOptions @return: GetSQLReviewCheckResultStatusResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetSQLReviewCheckResultStatus', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetSQLReviewCheckResultStatusResponse(), self.call_api(params, req, runtime) ) def get_sqlreview_check_result_status(self, request): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: GetSQLReviewCheckResultStatusRequest @return: GetSQLReviewCheckResultStatusResponse """ runtime = util_models.RuntimeOptions() return self.get_sqlreview_check_result_status_with_options(request, runtime) def get_sqlreview_optimize_detail_with_options(self, request, runtime): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: GetSQLReviewOptimizeDetailRequest @param runtime: runtime options for this request RuntimeOptions @return: GetSQLReviewOptimizeDetailResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.sqlreview_query_key): query['SQLReviewQueryKey'] = request.sqlreview_query_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetSQLReviewOptimizeDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetSQLReviewOptimizeDetailResponse(), self.call_api(params, req, runtime) ) def get_sqlreview_optimize_detail(self, request): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: GetSQLReviewOptimizeDetailRequest @return: GetSQLReviewOptimizeDetailResponse """ runtime = util_models.RuntimeOptions() return self.get_sqlreview_optimize_detail_with_options(request, runtime) def get_standard_group_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.group_id): query['GroupId'] = request.group_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetStandardGroup', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetStandardGroupResponse(), self.call_api(params, req, runtime) ) def get_standard_group(self, request): runtime = util_models.RuntimeOptions() return self.get_standard_group_with_options(request, runtime) def get_struct_sync_exec_sql_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetStructSyncExecSqlDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetStructSyncExecSqlDetailResponse(), self.call_api(params, req, runtime) ) def get_struct_sync_exec_sql_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_struct_sync_exec_sql_detail_with_options(request, runtime) def get_struct_sync_job_analyze_result_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.compare_type): query['CompareType'] = request.compare_type if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetStructSyncJobAnalyzeResult', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetStructSyncJobAnalyzeResultResponse(), self.call_api(params, req, runtime) ) def get_struct_sync_job_analyze_result(self, request): runtime = util_models.RuntimeOptions() return self.get_struct_sync_job_analyze_result_with_options(request, runtime) def get_struct_sync_job_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetStructSyncJobDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetStructSyncJobDetailResponse(), self.call_api(params, req, runtime) ) def get_struct_sync_job_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_struct_sync_job_detail_with_options(request, runtime) def get_struct_sync_order_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetStructSyncOrderDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetStructSyncOrderDetailResponse(), self.call_api(params, req, runtime) ) def get_struct_sync_order_detail(self, request): runtime = util_models.RuntimeOptions() return self.get_struct_sync_order_detail_with_options(request, runtime) def get_table_dbtopology_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.table_guid): query['TableGuid'] = request.table_guid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTableDBTopology', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTableDBTopologyResponse(), self.call_api(params, req, runtime) ) def get_table_dbtopology(self, request): runtime = util_models.RuntimeOptions() return self.get_table_dbtopology_with_options(request, runtime) def get_table_design_project_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTableDesignProjectFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTableDesignProjectFlowResponse(), self.call_api(params, req, runtime) ) def get_table_design_project_flow(self, request): runtime = util_models.RuntimeOptions() return self.get_table_design_project_flow_with_options(request, runtime) def get_table_design_project_info_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTableDesignProjectInfo', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTableDesignProjectInfoResponse(), self.call_api(params, req, runtime) ) def get_table_design_project_info(self, request): runtime = util_models.RuntimeOptions() return self.get_table_design_project_info_with_options(request, runtime) def get_table_topology_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.table_guid): query['TableGuid'] = request.table_guid if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTableTopology', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTableTopologyResponse(), self.call_api(params, req, runtime) ) def get_table_topology(self, request): runtime = util_models.RuntimeOptions() return self.get_table_topology_with_options(request, runtime) def get_task_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTask', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTaskResponse(), self.call_api(params, req, runtime) ) def get_task(self, request): runtime = util_models.RuntimeOptions() return self.get_task_with_options(request, runtime) def get_task_flow_graph_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTaskFlowGraph', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTaskFlowGraphResponse(), self.call_api(params, req, runtime) ) def get_task_flow_graph(self, request): runtime = util_models.RuntimeOptions() return self.get_task_flow_graph_with_options(request, runtime) def get_task_flow_notification_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTaskFlowNotification', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTaskFlowNotificationResponse(), self.call_api(params, req, runtime) ) def get_task_flow_notification(self, request): runtime = util_models.RuntimeOptions() return self.get_task_flow_notification_with_options(request, runtime) def get_task_instance_relation_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetTaskInstanceRelation', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetTaskInstanceRelationResponse(), self.call_api(params, req, runtime) ) def get_task_instance_relation(self, request): runtime = util_models.RuntimeOptions() return self.get_task_instance_relation_with_options(request, runtime) def get_user_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetUserResponse(), self.call_api(params, req, runtime) ) def get_user(self, request): runtime = util_models.RuntimeOptions() return self.get_user_with_options(request, runtime) def get_user_active_tenant_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetUserActiveTenant', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetUserActiveTenantResponse(), self.call_api(params, req, runtime) ) def get_user_active_tenant(self, request): runtime = util_models.RuntimeOptions() return self.get_user_active_tenant_with_options(request, runtime) def get_user_upload_file_job_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_key): query['JobKey'] = request.job_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GetUserUploadFileJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GetUserUploadFileJobResponse(), self.call_api(params, req, runtime) ) def get_user_upload_file_job(self, request): runtime = util_models.RuntimeOptions() return self.get_user_upload_file_job_with_options(request, runtime) def grant_template_authority_with_options(self, request, runtime): """ You must be a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GrantTemplateAuthorityRequest @param runtime: runtime options for this request RuntimeOptions @return: GrantTemplateAuthorityResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.comment): query['Comment'] = request.comment if not UtilClient.is_unset(request.expire_date): query['ExpireDate'] = request.expire_date if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_ids): query['UserIds'] = request.user_ids req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GrantTemplateAuthority', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GrantTemplateAuthorityResponse(), self.call_api(params, req, runtime) ) def grant_template_authority(self, request): """ You must be a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: GrantTemplateAuthorityRequest @return: GrantTemplateAuthorityResponse """ runtime = util_models.RuntimeOptions() return self.grant_template_authority_with_options(request, runtime) def grant_user_permission_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.ds_type): query['DsType'] = request.ds_type if not UtilClient.is_unset(request.expire_date): query['ExpireDate'] = request.expire_date if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.perm_types): query['PermTypes'] = request.perm_types if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='GrantUserPermission', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.GrantUserPermissionResponse(), self.call_api(params, req, runtime) ) def grant_user_permission(self, request): runtime = util_models.RuntimeOptions() return self.grant_user_permission_with_options(request, runtime) def inspect_proxy_access_secret_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_access_id): query['ProxyAccessId'] = request.proxy_access_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='InspectProxyAccessSecret', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.InspectProxyAccessSecretResponse(), self.call_api(params, req, runtime) ) def inspect_proxy_access_secret(self, request): runtime = util_models.RuntimeOptions() return self.inspect_proxy_access_secret_with_options(request, runtime) def list_authority_template_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListAuthorityTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListAuthorityTemplateResponse(), self.call_api(params, req, runtime) ) def list_authority_template(self, request): runtime = util_models.RuntimeOptions() return self.list_authority_template_with_options(request, runtime) def list_classification_templates_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListClassificationTemplates', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListClassificationTemplatesResponse(), self.call_api(params, req, runtime) ) def list_classification_templates(self, request): runtime = util_models.RuntimeOptions() return self.list_classification_templates_with_options(request, runtime) def list_columns_with_options(self, request, runtime): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: ListColumnsRequest @param runtime: runtime options for this request RuntimeOptions @return: ListColumnsResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListColumns', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListColumnsResponse(), self.call_api(params, req, runtime) ) def list_columns(self, request): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: ListColumnsRequest @return: ListColumnsResponse """ runtime = util_models.RuntimeOptions() return self.list_columns_with_options(request, runtime) def list_dagversions_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.page_index): query['PageIndex'] = request.page_index if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDAGVersions', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDAGVersionsResponse(), self.call_api(params, req, runtime) ) def list_dagversions(self, request): runtime = util_models.RuntimeOptions() return self.list_dagversions_with_options(request, runtime) def list_dbtask_sqljob_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dbtask_group_id): query['DBTaskGroupId'] = request.dbtask_group_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDBTaskSQLJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDBTaskSQLJobResponse(), self.call_api(params, req, runtime) ) def list_dbtask_sqljob(self, request): runtime = util_models.RuntimeOptions() return self.list_dbtask_sqljob_with_options(request, runtime) def list_dbtask_sqljob_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_id): query['JobId'] = request.job_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDBTaskSQLJobDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDBTaskSQLJobDetailResponse(), self.call_api(params, req, runtime) ) def list_dbtask_sqljob_detail(self, request): runtime = util_models.RuntimeOptions() return self.list_dbtask_sqljob_detail_with_options(request, runtime) def list_ddlpublish_records_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDDLPublishRecords', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDDLPublishRecordsResponse(), self.call_api(params, req, runtime) ) def list_ddlpublish_records(self, request): runtime = util_models.RuntimeOptions() return self.list_ddlpublish_records_with_options(request, runtime) def list_data_correct_pre_check_dbwith_options(self, request, runtime): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param request: ListDataCorrectPreCheckDBRequest @param runtime: runtime options for this request RuntimeOptions @return: ListDataCorrectPreCheckDBResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDataCorrectPreCheckDB', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDataCorrectPreCheckDBResponse(), self.call_api(params, req, runtime) ) def list_data_correct_pre_check_db(self, request): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param request: ListDataCorrectPreCheckDBRequest @return: ListDataCorrectPreCheckDBResponse """ runtime = util_models.RuntimeOptions() return self.list_data_correct_pre_check_dbwith_options(request, runtime) def list_data_correct_pre_check_sqlwith_options(self, request, runtime): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param request: ListDataCorrectPreCheckSQLRequest @param runtime: runtime options for this request RuntimeOptions @return: ListDataCorrectPreCheckSQLResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDataCorrectPreCheckSQL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDataCorrectPreCheckSQLResponse(), self.call_api(params, req, runtime) ) def list_data_correct_pre_check_sql(self, request): """ For more information about the Normal Data Modify feature, see [Change regular data](~~58419~~). @param request: ListDataCorrectPreCheckSQLRequest @return: ListDataCorrectPreCheckSQLResponse """ runtime = util_models.RuntimeOptions() return self.list_data_correct_pre_check_sqlwith_options(request, runtime) def list_data_import_sqlpre_check_detail_with_options(self, request, runtime): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: ListDataImportSQLPreCheckDetailRequest @param runtime: runtime options for this request RuntimeOptions @return: ListDataImportSQLPreCheckDetailResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.page_numer): query['PageNumer'] = request.page_numer if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.sql_type): query['SqlType'] = request.sql_type if not UtilClient.is_unset(request.status_code): query['StatusCode'] = request.status_code if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDataImportSQLPreCheckDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDataImportSQLPreCheckDetailResponse(), self.call_api(params, req, runtime) ) def list_data_import_sqlpre_check_detail(self, request): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: ListDataImportSQLPreCheckDetailRequest @return: ListDataImportSQLPreCheckDetailResponse """ runtime = util_models.RuntimeOptions() return self.list_data_import_sqlpre_check_detail_with_options(request, runtime) def list_data_import_sqltype_with_options(self, request, runtime): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: ListDataImportSQLTypeRequest @param runtime: runtime options for this request RuntimeOptions @return: ListDataImportSQLTypeResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDataImportSQLType', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDataImportSQLTypeResponse(), self.call_api(params, req, runtime) ) def list_data_import_sqltype(self, request): """ You can call this operation only if the data is imported in security mode in your data import ticket. @param request: ListDataImportSQLTypeRequest @return: ListDataImportSQLTypeResponse """ runtime = util_models.RuntimeOptions() return self.list_data_import_sqltype_with_options(request, runtime) def list_database_user_permssions_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.perm_type): query['PermType'] = request.perm_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_name): query['UserName'] = request.user_name req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDatabaseUserPermssions', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDatabaseUserPermssionsResponse(), self.call_api(params, req, runtime) ) def list_database_user_permssions(self, request): runtime = util_models.RuntimeOptions() return self.list_database_user_permssions_with_options(request, runtime) def list_databases_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDatabases', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDatabasesResponse(), self.call_api(params, req, runtime) ) def list_databases(self, request): runtime = util_models.RuntimeOptions() return self.list_databases_with_options(request, runtime) def list_default_slarules_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDefaultSLARules', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDefaultSLARulesResponse(), self.call_api(params, req, runtime) ) def list_default_slarules(self, request): runtime = util_models.RuntimeOptions() return self.list_default_slarules_with_options(request, runtime) def list_desensitization_rule_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.func_type): query['FuncType'] = request.func_type if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.rule_id): query['RuleId'] = request.rule_id if not UtilClient.is_unset(request.rule_name): query['RuleName'] = request.rule_name if not UtilClient.is_unset(request.rule_type): query['RuleType'] = request.rule_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListDesensitizationRule', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListDesensitizationRuleResponse(), self.call_api(params, req, runtime) ) def list_desensitization_rule(self, request): runtime = util_models.RuntimeOptions() return self.list_desensitization_rule_with_options(request, runtime) def list_effective_orders_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListEffectiveOrders', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListEffectiveOrdersResponse(), self.call_api(params, req, runtime) ) def list_effective_orders(self, request): runtime = util_models.RuntimeOptions() return self.list_effective_orders_with_options(request, runtime) def list_indexes_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListIndexes', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListIndexesResponse(), self.call_api(params, req, runtime) ) def list_indexes(self, request): runtime = util_models.RuntimeOptions() return self.list_indexes_with_options(request, runtime) def list_instance_login_audit_log_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.op_user_name): query['OpUserName'] = request.op_user_name if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListInstanceLoginAuditLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListInstanceLoginAuditLogResponse(), self.call_api(params, req, runtime) ) def list_instance_login_audit_log(self, request): runtime = util_models.RuntimeOptions() return self.list_instance_login_audit_log_with_options(request, runtime) def list_instance_user_permissions_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_name): query['UserName'] = request.user_name req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListInstanceUserPermissions', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListInstanceUserPermissionsResponse(), self.call_api(params, req, runtime) ) def list_instance_user_permissions(self, request): runtime = util_models.RuntimeOptions() return self.list_instance_user_permissions_with_options(request, runtime) def list_instances_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_type): query['DbType'] = request.db_type if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.instance_source): query['InstanceSource'] = request.instance_source if not UtilClient.is_unset(request.instance_state): query['InstanceState'] = request.instance_state if not UtilClient.is_unset(request.net_type): query['NetType'] = request.net_type if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListInstances', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListInstancesResponse(), self.call_api(params, req, runtime) ) def list_instances(self, request): runtime = util_models.RuntimeOptions() return self.list_instances_with_options(request, runtime) def list_lh_task_flow_and_scenario_with_options(self, request, runtime): """ Before you call this operation, make sure that you have the access permissions on the workspace. If you do not have the access permissions on the workspace, you can contact a DMS administrator, database administrator (DBA), or workspace administrator to add you as a member of the workspace. The [AddLhMembers](~~424759~~) operation can be called to add a workspace member. * If you are a DMS administrator or a workspace administrator, you can query the business scenarios and task flows related to a user in a workspace based on the user ID. @param request: ListLhTaskFlowAndScenarioRequest @param runtime: runtime options for this request RuntimeOptions @return: ListLhTaskFlowAndScenarioResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.space_id): query['SpaceId'] = request.space_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListLhTaskFlowAndScenario', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListLhTaskFlowAndScenarioResponse(), self.call_api(params, req, runtime) ) def list_lh_task_flow_and_scenario(self, request): """ Before you call this operation, make sure that you have the access permissions on the workspace. If you do not have the access permissions on the workspace, you can contact a DMS administrator, database administrator (DBA), or workspace administrator to add you as a member of the workspace. The [AddLhMembers](~~424759~~) operation can be called to add a workspace member. * If you are a DMS administrator or a workspace administrator, you can query the business scenarios and task flows related to a user in a workspace based on the user ID. @param request: ListLhTaskFlowAndScenarioRequest @return: ListLhTaskFlowAndScenarioResponse """ runtime = util_models.RuntimeOptions() return self.list_lh_task_flow_and_scenario_with_options(request, runtime) def list_logic_databases_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListLogicDatabases', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListLogicDatabasesResponse(), self.call_api(params, req, runtime) ) def list_logic_databases(self, request): runtime = util_models.RuntimeOptions() return self.list_logic_databases_with_options(request, runtime) def list_logic_table_route_config_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListLogicTableRouteConfig', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListLogicTableRouteConfigResponse(), self.call_api(params, req, runtime) ) def list_logic_table_route_config(self, request): runtime = util_models.RuntimeOptions() return self.list_logic_table_route_config_with_options(request, runtime) def list_logic_tables_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.database_id): query['DatabaseId'] = request.database_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.return_guid): query['ReturnGuid'] = request.return_guid if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListLogicTables', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListLogicTablesResponse(), self.call_api(params, req, runtime) ) def list_logic_tables(self, request): runtime = util_models.RuntimeOptions() return self.list_logic_tables_with_options(request, runtime) def list_orders_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.order_result_type): query['OrderResultType'] = request.order_result_type if not UtilClient.is_unset(request.order_status): query['OrderStatus'] = request.order_status if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.plugin_type): query['PluginType'] = request.plugin_type if not UtilClient.is_unset(request.search_content): query['SearchContent'] = request.search_content if not UtilClient.is_unset(request.search_date_type): query['SearchDateType'] = request.search_date_type if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListOrders', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListOrdersResponse(), self.call_api(params, req, runtime) ) def list_orders(self, request): runtime = util_models.RuntimeOptions() return self.list_orders_with_options(request, runtime) def list_proxies_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListProxies', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListProxiesResponse(), self.call_api(params, req, runtime) ) def list_proxies(self, request): runtime = util_models.RuntimeOptions() return self.list_proxies_with_options(request, runtime) def list_proxy_accesses_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.proxy_id): query['ProxyId'] = request.proxy_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListProxyAccesses', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListProxyAccessesResponse(), self.call_api(params, req, runtime) ) def list_proxy_accesses(self, request): runtime = util_models.RuntimeOptions() return self.list_proxy_accesses_with_options(request, runtime) def list_proxy_sqlexec_audit_log_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.exec_state): query['ExecState'] = request.exec_state if not UtilClient.is_unset(request.op_user_name): query['OpUserName'] = request.op_user_name if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.sqltype): query['SQLType'] = request.sqltype if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListProxySQLExecAuditLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListProxySQLExecAuditLogResponse(), self.call_api(params, req, runtime) ) def list_proxy_sqlexec_audit_log(self, request): runtime = util_models.RuntimeOptions() return self.list_proxy_sqlexec_audit_log_with_options(request, runtime) def list_slarules_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSLARules', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSLARulesResponse(), self.call_api(params, req, runtime) ) def list_slarules(self, request): runtime = util_models.RuntimeOptions() return self.list_slarules_with_options(request, runtime) def list_sqlexec_audit_log_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.exec_state): query['ExecState'] = request.exec_state if not UtilClient.is_unset(request.op_user_name): query['OpUserName'] = request.op_user_name if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.sql_type): query['SqlType'] = request.sql_type if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSQLExecAuditLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSQLExecAuditLogResponse(), self.call_api(params, req, runtime) ) def list_sqlexec_audit_log(self, request): runtime = util_models.RuntimeOptions() return self.list_sqlexec_audit_log_with_options(request, runtime) def list_sqlreview_origin_sqlwith_options(self, tmp_req, runtime): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param tmp_req: ListSQLReviewOriginSQLRequest @param runtime: runtime options for this request RuntimeOptions @return: ListSQLReviewOriginSQLResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.ListSQLReviewOriginSQLShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.order_action_detail): request.order_action_detail_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.order_action_detail, 'OrderActionDetail', 'json') query = {} if not UtilClient.is_unset(request.order_action_detail_shrink): query['OrderActionDetail'] = request.order_action_detail_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSQLReviewOriginSQL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSQLReviewOriginSQLResponse(), self.call_api(params, req, runtime) ) def list_sqlreview_origin_sql(self, request): """ For more information about the SQL review feature, see [SQL review](~~60374~~). @param request: ListSQLReviewOriginSQLRequest @return: ListSQLReviewOriginSQLResponse """ runtime = util_models.RuntimeOptions() return self.list_sqlreview_origin_sqlwith_options(request, runtime) def list_scenarios_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListScenarios', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListScenariosResponse(), self.call_api(params, req, runtime) ) def list_scenarios(self, request): runtime = util_models.RuntimeOptions() return self.list_scenarios_with_options(request, runtime) def list_sensitive_column_info_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSensitiveColumnInfo', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSensitiveColumnInfoResponse(), self.call_api(params, req, runtime) ) def list_sensitive_column_info(self, request): runtime = util_models.RuntimeOptions() return self.list_sensitive_column_info_with_options(request, runtime) def list_sensitive_columns_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.security_level): query['SecurityLevel'] = request.security_level if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSensitiveColumns', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSensitiveColumnsResponse(), self.call_api(params, req, runtime) ) def list_sensitive_columns(self, request): runtime = util_models.RuntimeOptions() return self.list_sensitive_columns_with_options(request, runtime) def list_sensitive_columns_detail_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSensitiveColumnsDetail', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSensitiveColumnsDetailResponse(), self.call_api(params, req, runtime) ) def list_sensitive_columns_detail(self, request): runtime = util_models.RuntimeOptions() return self.list_sensitive_columns_detail_with_options(request, runtime) def list_sensitive_data_audit_log_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_name): query['DbName'] = request.db_name if not UtilClient.is_unset(request.end_time): query['EndTime'] = request.end_time if not UtilClient.is_unset(request.module_name): query['ModuleName'] = request.module_name if not UtilClient.is_unset(request.op_user_name): query['OpUserName'] = request.op_user_name if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.start_time): query['StartTime'] = request.start_time if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSensitiveDataAuditLog', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSensitiveDataAuditLogResponse(), self.call_api(params, req, runtime) ) def list_sensitive_data_audit_log(self, request): runtime = util_models.RuntimeOptions() return self.list_sensitive_data_audit_log_with_options(request, runtime) def list_sensitivity_level_with_options(self, request, runtime): UtilClient.validate_model(request) query = OpenApiUtilClient.query(UtilClient.to_map(request)) req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListSensitivityLevel', version='2018-11-01', protocol='HTTPS', pathname='/', method='GET', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListSensitivityLevelResponse(), self.call_api(params, req, runtime) ) def list_sensitivity_level(self, request): runtime = util_models.RuntimeOptions() return self.list_sensitivity_level_with_options(request, runtime) def list_standard_groups_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListStandardGroups', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListStandardGroupsResponse(), self.call_api(params, req, runtime) ) def list_standard_groups(self, request): runtime = util_models.RuntimeOptions() return self.list_standard_groups_with_options(request, runtime) def list_tables_with_options(self, request, runtime): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: ListTablesRequest @param runtime: runtime options for this request RuntimeOptions @return: ListTablesResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.database_id): query['DatabaseId'] = request.database_id if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.return_guid): query['ReturnGuid'] = request.return_guid if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTables', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTablesResponse(), self.call_api(params, req, runtime) ) def list_tables(self, request): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: ListTablesRequest @return: ListTablesResponse """ runtime = util_models.RuntimeOptions() return self.list_tables_with_options(request, runtime) def list_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowResponse(), self.call_api(params, req, runtime) ) def list_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flow_with_options(request, runtime) def list_task_flow_constants_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowConstants', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowConstantsResponse(), self.call_api(params, req, runtime) ) def list_task_flow_constants(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flow_constants_with_options(request, runtime) def list_task_flow_cooperators_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowCooperators', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowCooperatorsResponse(), self.call_api(params, req, runtime) ) def list_task_flow_cooperators(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flow_cooperators_with_options(request, runtime) def list_task_flow_edges_by_condition_with_options(self, request, runtime): """ This operation is used for multi-condition query. You can call this operation to query the edges of a specified task flow that meet all specified conditions. @param request: ListTaskFlowEdgesByConditionRequest @param runtime: runtime options for this request RuntimeOptions @return: ListTaskFlowEdgesByConditionResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.id): query['Id'] = request.id if not UtilClient.is_unset(request.node_end): query['NodeEnd'] = request.node_end if not UtilClient.is_unset(request.node_from): query['NodeFrom'] = request.node_from if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowEdgesByCondition', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowEdgesByConditionResponse(), self.call_api(params, req, runtime) ) def list_task_flow_edges_by_condition(self, request): """ This operation is used for multi-condition query. You can call this operation to query the edges of a specified task flow that meet all specified conditions. @param request: ListTaskFlowEdgesByConditionRequest @return: ListTaskFlowEdgesByConditionResponse """ runtime = util_models.RuntimeOptions() return self.list_task_flow_edges_by_condition_with_options(request, runtime) def list_task_flow_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.page_index): query['PageIndex'] = request.page_index if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.start_time_begin): query['StartTimeBegin'] = request.start_time_begin if not UtilClient.is_unset(request.start_time_end): query['StartTimeEnd'] = request.start_time_end if not UtilClient.is_unset(request.status): query['Status'] = request.status if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.trigger_type): query['TriggerType'] = request.trigger_type if not UtilClient.is_unset(request.use_biz_date): query['UseBizDate'] = request.use_biz_date req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowInstanceResponse(), self.call_api(params, req, runtime) ) def list_task_flow_instance(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flow_instance_with_options(request, runtime) def list_task_flow_time_variables_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowTimeVariables', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowTimeVariablesResponse(), self.call_api(params, req, runtime) ) def list_task_flow_time_variables(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flow_time_variables_with_options(request, runtime) def list_task_flows_by_page_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.ListTaskFlowsByPageShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.dag_id_list): request.dag_id_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.dag_id_list, 'DagIdList', 'json') query = {} if not UtilClient.is_unset(request.dag_id_list_shrink): query['DagIdList'] = request.dag_id_list_shrink if not UtilClient.is_unset(request.page_index): query['PageIndex'] = request.page_index if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.scenario_id): query['ScenarioId'] = request.scenario_id if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTaskFlowsByPage', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTaskFlowsByPageResponse(), self.call_api(params, req, runtime) ) def list_task_flows_by_page(self, request): runtime = util_models.RuntimeOptions() return self.list_task_flows_by_page_with_options(request, runtime) def list_tasks_in_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListTasksInTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListTasksInTaskFlowResponse(), self.call_api(params, req, runtime) ) def list_tasks_in_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.list_tasks_in_task_flow_with_options(request, runtime) def list_user_permissions_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.database_name): query['DatabaseName'] = request.database_name if not UtilClient.is_unset(request.db_type): query['DbType'] = request.db_type if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.perm_type): query['PermType'] = request.perm_type if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListUserPermissions', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListUserPermissionsResponse(), self.call_api(params, req, runtime) ) def list_user_permissions(self, request): runtime = util_models.RuntimeOptions() return self.list_user_permissions_with_options(request, runtime) def list_user_tenants_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListUserTenants', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListUserTenantsResponse(), self.call_api(params, req, runtime) ) def list_user_tenants(self, request): runtime = util_models.RuntimeOptions() return self.list_user_tenants_with_options(request, runtime) def list_users_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.role): query['Role'] = request.role if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_state): query['UserState'] = request.user_state req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListUsers', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListUsersResponse(), self.call_api(params, req, runtime) ) def list_users(self, request): runtime = util_models.RuntimeOptions() return self.list_users_with_options(request, runtime) def list_work_flow_nodes_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListWorkFlowNodes', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListWorkFlowNodesResponse(), self.call_api(params, req, runtime) ) def list_work_flow_nodes(self, request): runtime = util_models.RuntimeOptions() return self.list_work_flow_nodes_with_options(request, runtime) def list_work_flow_templates_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.search_name): query['SearchName'] = request.search_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ListWorkFlowTemplates', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ListWorkFlowTemplatesResponse(), self.call_api(params, req, runtime) ) def list_work_flow_templates(self, request): runtime = util_models.RuntimeOptions() return self.list_work_flow_templates_with_options(request, runtime) def make_task_flow_instance_success_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='MakeTaskFlowInstanceSuccess', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.MakeTaskFlowInstanceSuccessResponse(), self.call_api(params, req, runtime) ) def make_task_flow_instance_success(self, request): runtime = util_models.RuntimeOptions() return self.make_task_flow_instance_success_with_options(request, runtime) def modify_data_correct_exec_sqlwith_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.exec_sql): query['ExecSQL'] = request.exec_sql if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ModifyDataCorrectExecSQL', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ModifyDataCorrectExecSQLResponse(), self.call_api(params, req, runtime) ) def modify_data_correct_exec_sql(self, request): runtime = util_models.RuntimeOptions() return self.modify_data_correct_exec_sqlwith_options(request, runtime) def modify_desensitization_strategy_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.column_name): query['ColumnName'] = request.column_name if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.is_default): query['IsDefault'] = request.is_default if not UtilClient.is_unset(request.is_logic): query['IsLogic'] = request.is_logic if not UtilClient.is_unset(request.is_reset): query['IsReset'] = request.is_reset if not UtilClient.is_unset(request.rule_id): query['RuleId'] = request.rule_id if not UtilClient.is_unset(request.schema_name): query['SchemaName'] = request.schema_name if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ModifyDesensitizationStrategy', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ModifyDesensitizationStrategyResponse(), self.call_api(params, req, runtime) ) def modify_desensitization_strategy(self, request): runtime = util_models.RuntimeOptions() return self.modify_desensitization_strategy_with_options(request, runtime) def modify_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.data_link_name): query['DataLinkName'] = request.data_link_name if not UtilClient.is_unset(request.database_password): query['DatabasePassword'] = request.database_password if not UtilClient.is_unset(request.database_user): query['DatabaseUser'] = request.database_user if not UtilClient.is_unset(request.dba_id): query['DbaId'] = request.dba_id if not UtilClient.is_unset(request.ddl_online): query['DdlOnline'] = request.ddl_online if not UtilClient.is_unset(request.ecs_instance_id): query['EcsInstanceId'] = request.ecs_instance_id if not UtilClient.is_unset(request.ecs_region): query['EcsRegion'] = request.ecs_region if not UtilClient.is_unset(request.enable_sell_common): query['EnableSellCommon'] = request.enable_sell_common if not UtilClient.is_unset(request.enable_sell_sitd): query['EnableSellSitd'] = request.enable_sell_sitd if not UtilClient.is_unset(request.enable_sell_stable): query['EnableSellStable'] = request.enable_sell_stable if not UtilClient.is_unset(request.enable_sell_trust): query['EnableSellTrust'] = request.enable_sell_trust if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.export_timeout): query['ExportTimeout'] = request.export_timeout if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.instance_alias): query['InstanceAlias'] = request.instance_alias if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.instance_source): query['InstanceSource'] = request.instance_source if not UtilClient.is_unset(request.instance_type): query['InstanceType'] = request.instance_type if not UtilClient.is_unset(request.network_type): query['NetworkType'] = request.network_type if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.query_timeout): query['QueryTimeout'] = request.query_timeout if not UtilClient.is_unset(request.safe_rule): query['SafeRule'] = request.safe_rule if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.skip_test): query['SkipTest'] = request.skip_test if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.template_type): query['TemplateType'] = request.template_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.use_dsql): query['UseDsql'] = request.use_dsql if not UtilClient.is_unset(request.use_ssl): query['UseSsl'] = request.use_ssl if not UtilClient.is_unset(request.vpc_id): query['VpcId'] = request.vpc_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ModifyInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ModifyInstanceResponse(), self.call_api(params, req, runtime) ) def modify_instance(self, request): runtime = util_models.RuntimeOptions() return self.modify_instance_with_options(request, runtime) def move_task_flow_to_scenario_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.scenario_id): query['ScenarioId'] = request.scenario_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='MoveTaskFlowToScenario', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.MoveTaskFlowToScenarioResponse(), self.call_api(params, req, runtime) ) def move_task_flow_to_scenario(self, request): runtime = util_models.RuntimeOptions() return self.move_task_flow_to_scenario_with_options(request, runtime) def offline_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='OfflineTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.OfflineTaskFlowResponse(), self.call_api(params, req, runtime) ) def offline_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.offline_task_flow_with_options(request, runtime) def pause_data_correct_sqljob_with_options(self, request, runtime): """ You can call this operation only for database instances that are managed in Security Collaboration mode. @param request: PauseDataCorrectSQLJobRequest @param runtime: runtime options for this request RuntimeOptions @return: PauseDataCorrectSQLJobResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_id): query['JobId'] = request.job_id if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.type): query['Type'] = request.type req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='PauseDataCorrectSQLJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.PauseDataCorrectSQLJobResponse(), self.call_api(params, req, runtime) ) def pause_data_correct_sqljob(self, request): """ You can call this operation only for database instances that are managed in Security Collaboration mode. @param request: PauseDataCorrectSQLJobRequest @return: PauseDataCorrectSQLJobResponse """ runtime = util_models.RuntimeOptions() return self.pause_data_correct_sqljob_with_options(request, runtime) def preview_workflow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='PreviewWorkflow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.PreviewWorkflowResponse(), self.call_api(params, req, runtime) ) def preview_workflow(self, request): runtime = util_models.RuntimeOptions() return self.preview_workflow_with_options(request, runtime) def publish_and_deploy_task_flow_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.version_comments): query['VersionComments'] = request.version_comments req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='PublishAndDeployTaskFlow', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.PublishAndDeployTaskFlowResponse(), self.call_api(params, req, runtime) ) def publish_and_deploy_task_flow(self, request): runtime = util_models.RuntimeOptions() return self.publish_and_deploy_task_flow_with_options(request, runtime) def query_data_track_result_download_status_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.download_key_id): query['DownloadKeyId'] = request.download_key_id if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='QueryDataTrackResultDownloadStatus', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.QueryDataTrackResultDownloadStatusResponse(), self.call_api(params, req, runtime) ) def query_data_track_result_download_status(self, request): runtime = util_models.RuntimeOptions() return self.query_data_track_result_download_status_with_options(request, runtime) def re_deploy_lh_dag_version_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_version): query['DagVersion'] = request.dag_version if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ReDeployLhDagVersion', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ReDeployLhDagVersionResponse(), self.call_api(params, req, runtime) ) def re_deploy_lh_dag_version(self, request): runtime = util_models.RuntimeOptions() return self.re_deploy_lh_dag_version_with_options(request, runtime) def re_run_task_flow_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.dag_version): query['DagVersion'] = request.dag_version if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ReRunTaskFlowInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ReRunTaskFlowInstanceResponse(), self.call_api(params, req, runtime) ) def re_run_task_flow_instance(self, request): runtime = util_models.RuntimeOptions() return self.re_run_task_flow_instance_with_options(request, runtime) def refund_pay_as_you_go_order_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RefundPayAsYouGoOrder', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RefundPayAsYouGoOrderResponse(), self.call_api(params, req, runtime) ) def refund_pay_as_you_go_order(self, request): runtime = util_models.RuntimeOptions() return self.refund_pay_as_you_go_order_with_options(request, runtime) def register_instance_with_options(self, request, runtime): """ Prerequisites: You are a DMS administrator or a database administrator (DBA). You can call the [ListUsers](~~141938~~) or [GetUser](~~147098~~) operation to query your user role from the RoleIdList parameter that is returned. @param request: RegisterInstanceRequest @param runtime: runtime options for this request RuntimeOptions @return: RegisterInstanceResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.data_link_name): query['DataLinkName'] = request.data_link_name if not UtilClient.is_unset(request.database_password): query['DatabasePassword'] = request.database_password if not UtilClient.is_unset(request.database_user): query['DatabaseUser'] = request.database_user if not UtilClient.is_unset(request.dba_uid): query['DbaUid'] = request.dba_uid if not UtilClient.is_unset(request.dba_uid_by_string): query['DbaUidByString'] = request.dba_uid_by_string if not UtilClient.is_unset(request.ddl_online): query['DdlOnline'] = request.ddl_online if not UtilClient.is_unset(request.ecs_instance_id): query['EcsInstanceId'] = request.ecs_instance_id if not UtilClient.is_unset(request.ecs_region): query['EcsRegion'] = request.ecs_region if not UtilClient.is_unset(request.enable_sell_sitd): query['EnableSellSitd'] = request.enable_sell_sitd if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.export_timeout): query['ExportTimeout'] = request.export_timeout if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.instance_alias): query['InstanceAlias'] = request.instance_alias if not UtilClient.is_unset(request.instance_source): query['InstanceSource'] = request.instance_source if not UtilClient.is_unset(request.instance_type): query['InstanceType'] = request.instance_type if not UtilClient.is_unset(request.network_type): query['NetworkType'] = request.network_type if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.query_timeout): query['QueryTimeout'] = request.query_timeout if not UtilClient.is_unset(request.safe_rule): query['SafeRule'] = request.safe_rule if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.skip_test): query['SkipTest'] = request.skip_test if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.template_type): query['TemplateType'] = request.template_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.use_dsql): query['UseDsql'] = request.use_dsql if not UtilClient.is_unset(request.vpc_id): query['VpcId'] = request.vpc_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RegisterInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RegisterInstanceResponse(), self.call_api(params, req, runtime) ) def register_instance(self, request): """ Prerequisites: You are a DMS administrator or a database administrator (DBA). You can call the [ListUsers](~~141938~~) or [GetUser](~~147098~~) operation to query your user role from the RoleIdList parameter that is returned. @param request: RegisterInstanceRequest @return: RegisterInstanceResponse """ runtime = util_models.RuntimeOptions() return self.register_instance_with_options(request, runtime) def register_user_with_options(self, request, runtime): """ If you are an *administrator** in Data Management (DMS), you can call this operation to register a user for your enterprise. To view users that are assigned the administrator role, perform the following steps: Log on to the DMS console. In the top navigation bar, click O&M. In the left-side navigation pane, click User. @param request: RegisterUserRequest @param runtime: runtime options for this request RuntimeOptions @return: RegisterUserResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.mobile): query['Mobile'] = request.mobile if not UtilClient.is_unset(request.role_names): query['RoleNames'] = request.role_names if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid if not UtilClient.is_unset(request.user_nick): query['UserNick'] = request.user_nick req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RegisterUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RegisterUserResponse(), self.call_api(params, req, runtime) ) def register_user(self, request): """ If you are an *administrator** in Data Management (DMS), you can call this operation to register a user for your enterprise. To view users that are assigned the administrator role, perform the following steps: Log on to the DMS console. In the top navigation bar, click O&M. In the left-side navigation pane, click User. @param request: RegisterUserRequest @return: RegisterUserResponse """ runtime = util_models.RuntimeOptions() return self.register_user_with_options(request, runtime) def restart_data_correct_sqljob_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.job_id): query['JobId'] = request.job_id if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.type): query['Type'] = request.type req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RestartDataCorrectSQLJob', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RestartDataCorrectSQLJobResponse(), self.call_api(params, req, runtime) ) def restart_data_correct_sqljob(self, request): runtime = util_models.RuntimeOptions() return self.restart_data_correct_sqljob_with_options(request, runtime) def resume_task_flow_instance_with_options(self, request, runtime): """ You can call this operation only for task flows that are suspended. @param request: ResumeTaskFlowInstanceRequest @param runtime: runtime options for this request RuntimeOptions @return: ResumeTaskFlowInstanceResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.dag_version): query['DagVersion'] = request.dag_version if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='ResumeTaskFlowInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.ResumeTaskFlowInstanceResponse(), self.call_api(params, req, runtime) ) def resume_task_flow_instance(self, request): """ You can call this operation only for task flows that are suspended. @param request: ResumeTaskFlowInstanceRequest @return: ResumeTaskFlowInstanceResponse """ runtime = util_models.RuntimeOptions() return self.resume_task_flow_instance_with_options(request, runtime) def retry_data_correct_pre_check_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RetryDataCorrectPreCheck', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RetryDataCorrectPreCheckResponse(), self.call_api(params, req, runtime) ) def retry_data_correct_pre_check(self, request): runtime = util_models.RuntimeOptions() return self.retry_data_correct_pre_check_with_options(request, runtime) def revoke_template_authority_with_options(self, request, runtime): """ You must be a database administrator (DBA) or a DMS administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: RevokeTemplateAuthorityRequest @param runtime: runtime options for this request RuntimeOptions @return: RevokeTemplateAuthorityResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_ids): query['UserIds'] = request.user_ids req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RevokeTemplateAuthority', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RevokeTemplateAuthorityResponse(), self.call_api(params, req, runtime) ) def revoke_template_authority(self, request): """ You must be a database administrator (DBA) or a DMS administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: RevokeTemplateAuthorityRequest @return: RevokeTemplateAuthorityResponse """ runtime = util_models.RuntimeOptions() return self.revoke_template_authority_with_options(request, runtime) def revoke_user_permission_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.ds_type): query['DsType'] = request.ds_type if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.perm_types): query['PermTypes'] = request.perm_types if not UtilClient.is_unset(request.table_id): query['TableId'] = request.table_id if not UtilClient.is_unset(request.table_name): query['TableName'] = request.table_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.user_access_id): query['UserAccessId'] = request.user_access_id if not UtilClient.is_unset(request.user_id): query['UserId'] = request.user_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='RevokeUserPermission', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.RevokeUserPermissionResponse(), self.call_api(params, req, runtime) ) def revoke_user_permission(self, request): runtime = util_models.RuntimeOptions() return self.revoke_user_permission_with_options(request, runtime) def search_data_track_result_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.SearchDataTrackResultShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.column_filter): request.column_filter_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.column_filter, 'ColumnFilter', 'json') if not UtilClient.is_unset(tmp_req.filter_table_list): request.filter_table_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.filter_table_list, 'FilterTableList', 'json') if not UtilClient.is_unset(tmp_req.filter_type_list): request.filter_type_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.filter_type_list, 'FilterTypeList', 'json') query = {} if not UtilClient.is_unset(request.column_filter_shrink): query['ColumnFilter'] = request.column_filter_shrink if not UtilClient.is_unset(request.filter_end_time): query['FilterEndTime'] = request.filter_end_time if not UtilClient.is_unset(request.filter_start_time): query['FilterStartTime'] = request.filter_start_time if not UtilClient.is_unset(request.filter_table_list_shrink): query['FilterTableList'] = request.filter_table_list_shrink if not UtilClient.is_unset(request.filter_type_list_shrink): query['FilterTypeList'] = request.filter_type_list_shrink if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SearchDataTrackResult', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SearchDataTrackResultResponse(), self.call_api(params, req, runtime) ) def search_data_track_result(self, request): runtime = util_models.RuntimeOptions() return self.search_data_track_result_with_options(request, runtime) def search_database_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_type): query['DbType'] = request.db_type if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.search_range): query['SearchRange'] = request.search_range if not UtilClient.is_unset(request.search_target): query['SearchTarget'] = request.search_target if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SearchDatabase', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SearchDatabaseResponse(), self.call_api(params, req, runtime) ) def search_database(self, request): runtime = util_models.RuntimeOptions() return self.search_database_with_options(request, runtime) def search_table_with_options(self, request, runtime): """ You can call this operation only for database instances that are managed in Security Collaboration mode. @param request: SearchTableRequest @param runtime: runtime options for this request RuntimeOptions @return: SearchTableResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_type): query['DbType'] = request.db_type if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.page_number): query['PageNumber'] = request.page_number if not UtilClient.is_unset(request.page_size): query['PageSize'] = request.page_size if not UtilClient.is_unset(request.return_guid): query['ReturnGuid'] = request.return_guid if not UtilClient.is_unset(request.search_key): query['SearchKey'] = request.search_key if not UtilClient.is_unset(request.search_range): query['SearchRange'] = request.search_range if not UtilClient.is_unset(request.search_target): query['SearchTarget'] = request.search_target if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SearchTable', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SearchTableResponse(), self.call_api(params, req, runtime) ) def search_table(self, request): """ You can call this operation only for database instances that are managed in Security Collaboration mode. @param request: SearchTableRequest @return: SearchTableResponse """ runtime = util_models.RuntimeOptions() return self.search_table_with_options(request, runtime) def set_owners_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.owner_ids): query['OwnerIds'] = request.owner_ids if not UtilClient.is_unset(request.owner_type): query['OwnerType'] = request.owner_type if not UtilClient.is_unset(request.resource_id): query['ResourceId'] = request.resource_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SetOwners', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SetOwnersResponse(), self.call_api(params, req, runtime) ) def set_owners(self, request): runtime = util_models.RuntimeOptions() return self.set_owners_with_options(request, runtime) def skip_data_correct_row_check_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.reason): query['Reason'] = request.reason if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SkipDataCorrectRowCheck', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SkipDataCorrectRowCheckResponse(), self.call_api(params, req, runtime) ) def skip_data_correct_row_check(self, request): runtime = util_models.RuntimeOptions() return self.skip_data_correct_row_check_with_options(request, runtime) def stop_task_flow_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='StopTaskFlowInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.StopTaskFlowInstanceResponse(), self.call_api(params, req, runtime) ) def stop_task_flow_instance(self, request): runtime = util_models.RuntimeOptions() return self.stop_task_flow_instance_with_options(request, runtime) def submit_order_approval_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SubmitOrderApproval', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SubmitOrderApprovalResponse(), self.call_api(params, req, runtime) ) def submit_order_approval(self, request): runtime = util_models.RuntimeOptions() return self.submit_order_approval_with_options(request, runtime) def submit_struct_sync_order_approval_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.order_id): query['OrderId'] = request.order_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SubmitStructSyncOrderApproval', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SubmitStructSyncOrderApprovalResponse(), self.call_api(params, req, runtime) ) def submit_struct_sync_order_approval(self, request): runtime = util_models.RuntimeOptions() return self.submit_struct_sync_order_approval_with_options(request, runtime) def suspend_task_flow_instance_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_instance_id): query['DagInstanceId'] = request.dag_instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SuspendTaskFlowInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SuspendTaskFlowInstanceResponse(), self.call_api(params, req, runtime) ) def suspend_task_flow_instance(self, request): runtime = util_models.RuntimeOptions() return self.suspend_task_flow_instance_with_options(request, runtime) def sync_database_meta_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.db_id): query['DbId'] = request.db_id if not UtilClient.is_unset(request.logic): query['Logic'] = request.logic if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SyncDatabaseMeta', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SyncDatabaseMetaResponse(), self.call_api(params, req, runtime) ) def sync_database_meta(self, request): runtime = util_models.RuntimeOptions() return self.sync_database_meta_with_options(request, runtime) def sync_instance_meta_with_options(self, request, runtime): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: SyncInstanceMetaRequest @param runtime: runtime options for this request RuntimeOptions @return: SyncInstanceMetaResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.ignore_table): query['IgnoreTable'] = request.ignore_table if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='SyncInstanceMeta', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.SyncInstanceMetaResponse(), self.call_api(params, req, runtime) ) def sync_instance_meta(self, request): """ You can call this operation only for database instances whose control mode is Security Collaboration. @param request: SyncInstanceMetaRequest @return: SyncInstanceMetaResponse """ runtime = util_models.RuntimeOptions() return self.sync_instance_meta_with_options(request, runtime) def update_authority_template_with_options(self, request, runtime): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: UpdateAuthorityTemplateRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateAuthorityTemplateResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.name): query['Name'] = request.name if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateAuthorityTemplate', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateAuthorityTemplateResponse(), self.call_api(params, req, runtime) ) def update_authority_template(self, request): """ You are a database administrator (DBA) or a Data Management (DMS) administrator. For more information about how to view system roles, see [View system roles](~~324212~~). @param request: UpdateAuthorityTemplateRequest @return: UpdateAuthorityTemplateResponse """ runtime = util_models.RuntimeOptions() return self.update_authority_template_with_options(request, runtime) def update_instance_with_options(self, request, runtime): """ Before you call the UpdateInstance operation, call the [GetInstance](~~141567~~) or [ListInstances](~~141936~~) operation to obtain the complete information about the instance. @param request: UpdateInstanceRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateInstanceResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.data_link_name): query['DataLinkName'] = request.data_link_name if not UtilClient.is_unset(request.database_password): query['DatabasePassword'] = request.database_password if not UtilClient.is_unset(request.database_user): query['DatabaseUser'] = request.database_user if not UtilClient.is_unset(request.dba_id): query['DbaId'] = request.dba_id if not UtilClient.is_unset(request.ddl_online): query['DdlOnline'] = request.ddl_online if not UtilClient.is_unset(request.ecs_instance_id): query['EcsInstanceId'] = request.ecs_instance_id if not UtilClient.is_unset(request.ecs_region): query['EcsRegion'] = request.ecs_region if not UtilClient.is_unset(request.enable_sell_sitd): query['EnableSellSitd'] = request.enable_sell_sitd if not UtilClient.is_unset(request.env_type): query['EnvType'] = request.env_type if not UtilClient.is_unset(request.export_timeout): query['ExportTimeout'] = request.export_timeout if not UtilClient.is_unset(request.host): query['Host'] = request.host if not UtilClient.is_unset(request.instance_alias): query['InstanceAlias'] = request.instance_alias if not UtilClient.is_unset(request.instance_id): query['InstanceId'] = request.instance_id if not UtilClient.is_unset(request.instance_source): query['InstanceSource'] = request.instance_source if not UtilClient.is_unset(request.instance_type): query['InstanceType'] = request.instance_type if not UtilClient.is_unset(request.port): query['Port'] = request.port if not UtilClient.is_unset(request.query_timeout): query['QueryTimeout'] = request.query_timeout if not UtilClient.is_unset(request.safe_rule_id): query['SafeRuleId'] = request.safe_rule_id if not UtilClient.is_unset(request.sid): query['Sid'] = request.sid if not UtilClient.is_unset(request.skip_test): query['SkipTest'] = request.skip_test if not UtilClient.is_unset(request.template_id): query['TemplateId'] = request.template_id if not UtilClient.is_unset(request.template_type): query['TemplateType'] = request.template_type if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.use_dsql): query['UseDsql'] = request.use_dsql if not UtilClient.is_unset(request.vpc_id): query['VpcId'] = request.vpc_id req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateInstance', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateInstanceResponse(), self.call_api(params, req, runtime) ) def update_instance(self, request): """ Before you call the UpdateInstance operation, call the [GetInstance](~~141567~~) or [ListInstances](~~141936~~) operation to obtain the complete information about the instance. @param request: UpdateInstanceRequest @return: UpdateInstanceResponse """ runtime = util_models.RuntimeOptions() return self.update_instance_with_options(request, runtime) def update_slarules_with_options(self, tmp_req, runtime): """ SLA rules take effect after task flows are deployed and published. @param tmp_req: UpdateSLARulesRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateSLARulesResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.UpdateSLARulesShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.sla_rule_list): request.sla_rule_list_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.sla_rule_list, 'SlaRuleList', 'json') query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.sla_rule_list_shrink): query['SlaRuleList'] = request.sla_rule_list_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateSLARules', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateSLARulesResponse(), self.call_api(params, req, runtime) ) def update_slarules(self, request): """ SLA rules take effect after task flows are deployed and published. @param request: UpdateSLARulesRequest @return: UpdateSLARulesResponse """ runtime = util_models.RuntimeOptions() return self.update_slarules_with_options(request, runtime) def update_scenario_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.scenario_id): query['ScenarioId'] = request.scenario_id if not UtilClient.is_unset(request.scenario_name): query['ScenarioName'] = request.scenario_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateScenario', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateScenarioResponse(), self.call_api(params, req, runtime) ) def update_scenario(self, request): runtime = util_models.RuntimeOptions() return self.update_scenario_with_options(request, runtime) def update_standard_group_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.group_id): query['GroupId'] = request.group_id if not UtilClient.is_unset(request.group_name): query['GroupName'] = request.group_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateStandardGroup', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateStandardGroupResponse(), self.call_api(params, req, runtime) ) def update_standard_group(self, request): runtime = util_models.RuntimeOptions() return self.update_standard_group_with_options(request, runtime) def update_task_config_with_options(self, request, runtime): """ You can call this operation to configure a failed task or rerun a task. @param request: UpdateTaskConfigRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskConfigResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_config): query['NodeConfig'] = request.node_config if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskConfig', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskConfigResponse(), self.call_api(params, req, runtime) ) def update_task_config(self, request): """ You can call this operation to configure a failed task or rerun a task. @param request: UpdateTaskConfigRequest @return: UpdateTaskConfigResponse """ runtime = util_models.RuntimeOptions() return self.update_task_config_with_options(request, runtime) def update_task_content_with_options(self, request, runtime): """ You can call this operation to modify node configurations. @param request: UpdateTaskContentRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskContentResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_content): query['NodeContent'] = request.node_content if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskContent', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskContentResponse(), self.call_api(params, req, runtime) ) def update_task_content(self, request): """ You can call this operation to modify node configurations. @param request: UpdateTaskContentRequest @return: UpdateTaskContentResponse """ runtime = util_models.RuntimeOptions() return self.update_task_content_with_options(request, runtime) def update_task_flow_constants_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.UpdateTaskFlowConstantsShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.dag_constants): request.dag_constants_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.dag_constants, 'DagConstants', 'json') query = {} if not UtilClient.is_unset(request.dag_constants_shrink): query['DagConstants'] = request.dag_constants_shrink if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowConstants', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowConstantsResponse(), self.call_api(params, req, runtime) ) def update_task_flow_constants(self, request): runtime = util_models.RuntimeOptions() return self.update_task_flow_constants_with_options(request, runtime) def update_task_flow_cooperators_with_options(self, tmp_req, runtime): UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.UpdateTaskFlowCooperatorsShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.cooperator_ids): request.cooperator_ids_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.cooperator_ids, 'CooperatorIds', 'json') query = {} if not UtilClient.is_unset(request.cooperator_ids_shrink): query['CooperatorIds'] = request.cooperator_ids_shrink if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowCooperators', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowCooperatorsResponse(), self.call_api(params, req, runtime) ) def update_task_flow_cooperators(self, request): runtime = util_models.RuntimeOptions() return self.update_task_flow_cooperators_with_options(request, runtime) def update_task_flow_edges_with_options(self, tmp_req, runtime): """ ### The edges can be updated only when the following conditions are met: 1. The specified edge exists in the directed acyclic graph (DAG) of the task flow specified by DagId. 2. The specified edge nodes exist in the DAG of the task flow specified by DagId. 3. After the update, rings do not exist in the DAG. @param tmp_req: UpdateTaskFlowEdgesRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskFlowEdgesResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.UpdateTaskFlowEdgesShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.edges): request.edges_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.edges, 'Edges', 'json') query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.edges_shrink): query['Edges'] = request.edges_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowEdges', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowEdgesResponse(), self.call_api(params, req, runtime) ) def update_task_flow_edges(self, request): """ ### The edges can be updated only when the following conditions are met: 1. The specified edge exists in the directed acyclic graph (DAG) of the task flow specified by DagId. 2. The specified edge nodes exist in the DAG of the task flow specified by DagId. 3. After the update, rings do not exist in the DAG. @param request: UpdateTaskFlowEdgesRequest @return: UpdateTaskFlowEdgesResponse """ runtime = util_models.RuntimeOptions() return self.update_task_flow_edges_with_options(request, runtime) def update_task_flow_name_and_desc_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_name): query['DagName'] = request.dag_name if not UtilClient.is_unset(request.description): query['Description'] = request.description if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowNameAndDesc', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowNameAndDescResponse(), self.call_api(params, req, runtime) ) def update_task_flow_name_and_desc(self, request): runtime = util_models.RuntimeOptions() return self.update_task_flow_name_and_desc_with_options(request, runtime) def update_task_flow_notification_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.dag_notification_fail): query['DagNotificationFail'] = request.dag_notification_fail if not UtilClient.is_unset(request.dag_notification_sla): query['DagNotificationSla'] = request.dag_notification_sla if not UtilClient.is_unset(request.dag_notification_success): query['DagNotificationSuccess'] = request.dag_notification_success if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowNotification', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowNotificationResponse(), self.call_api(params, req, runtime) ) def update_task_flow_notification(self, request): runtime = util_models.RuntimeOptions() return self.update_task_flow_notification_with_options(request, runtime) def update_task_flow_owner_with_options(self, request, runtime): """ Note: The new owner of the task flow must belong to the same tenant as the previous owner. @param request: UpdateTaskFlowOwnerRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskFlowOwnerResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.new_owner_id): query['NewOwnerId'] = request.new_owner_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowOwner', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowOwnerResponse(), self.call_api(params, req, runtime) ) def update_task_flow_owner(self, request): """ Note: The new owner of the task flow must belong to the same tenant as the previous owner. @param request: UpdateTaskFlowOwnerRequest @return: UpdateTaskFlowOwnerResponse """ runtime = util_models.RuntimeOptions() return self.update_task_flow_owner_with_options(request, runtime) def update_task_flow_relations_with_options(self, tmp_req, runtime): """ You can call this operation to perform a full update. For incremental updates, see AddTaskFlowEdges, UpdateTaskFlowEdges, and DeleteTaskFlowEdgesByMultiCondition. @param tmp_req: UpdateTaskFlowRelationsRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskFlowRelationsResponse """ UtilClient.validate_model(tmp_req) request = dms_enterprise_20181101_models.UpdateTaskFlowRelationsShrinkRequest() OpenApiUtilClient.convert(tmp_req, request) if not UtilClient.is_unset(tmp_req.edges): request.edges_shrink = OpenApiUtilClient.array_to_string_with_specified_style(tmp_req.edges, 'Edges', 'json') query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.edges_shrink): query['Edges'] = request.edges_shrink if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowRelations', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowRelationsResponse(), self.call_api(params, req, runtime) ) def update_task_flow_relations(self, request): """ You can call this operation to perform a full update. For incremental updates, see AddTaskFlowEdges, UpdateTaskFlowEdges, and DeleteTaskFlowEdgesByMultiCondition. @param request: UpdateTaskFlowRelationsRequest @return: UpdateTaskFlowRelationsResponse """ runtime = util_models.RuntimeOptions() return self.update_task_flow_relations_with_options(request, runtime) def update_task_flow_schedule_with_options(self, request, runtime): """ You can call this operation to update the scheduling properties for a task flow in the editing state. You can configure a *timed scheduling** task flow or an **event scheduling** task flow. When you configure a **timed scheduling** task flow, you can choose from one-time scheduling or periodic scheduling. When you configure an **event scheduling** task flow, you can subscribe to task flows or task flow nodes.****\\ After you update the scheduling properties, you need to publish and deploy the task flow again. The new task flow instance will run based on the updated scheduling properties. @param request: UpdateTaskFlowScheduleRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskFlowScheduleResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.cron_begin_date): query['CronBeginDate'] = request.cron_begin_date if not UtilClient.is_unset(request.cron_end_date): query['CronEndDate'] = request.cron_end_date if not UtilClient.is_unset(request.cron_str): query['CronStr'] = request.cron_str if not UtilClient.is_unset(request.cron_type): query['CronType'] = request.cron_type if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.schedule_param): query['ScheduleParam'] = request.schedule_param if not UtilClient.is_unset(request.schedule_switch): query['ScheduleSwitch'] = request.schedule_switch if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.time_zone_id): query['TimeZoneId'] = request.time_zone_id if not UtilClient.is_unset(request.trigger_type): query['TriggerType'] = request.trigger_type req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowSchedule', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowScheduleResponse(), self.call_api(params, req, runtime) ) def update_task_flow_schedule(self, request): """ You can call this operation to update the scheduling properties for a task flow in the editing state. You can configure a *timed scheduling** task flow or an **event scheduling** task flow. When you configure a **timed scheduling** task flow, you can choose from one-time scheduling or periodic scheduling. When you configure an **event scheduling** task flow, you can subscribe to task flows or task flow nodes.****\\ After you update the scheduling properties, you need to publish and deploy the task flow again. The new task flow instance will run based on the updated scheduling properties. @param request: UpdateTaskFlowScheduleRequest @return: UpdateTaskFlowScheduleResponse """ runtime = util_models.RuntimeOptions() return self.update_task_flow_schedule_with_options(request, runtime) def update_task_flow_time_variables_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.dag_id): query['DagId'] = request.dag_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.time_variables): query['TimeVariables'] = request.time_variables req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskFlowTimeVariables', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskFlowTimeVariablesResponse(), self.call_api(params, req, runtime) ) def update_task_flow_time_variables(self, request): runtime = util_models.RuntimeOptions() return self.update_task_flow_time_variables_with_options(request, runtime) def update_task_name_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.node_name): query['NodeName'] = request.node_name if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskName', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskNameResponse(), self.call_api(params, req, runtime) ) def update_task_name(self, request): runtime = util_models.RuntimeOptions() return self.update_task_name_with_options(request, runtime) def update_task_output_with_options(self, request, runtime): """ Only nodes of single-instance SQL assignment, script code, and ECS remote command have output variables. @param request: UpdateTaskOutputRequest @param runtime: runtime options for this request RuntimeOptions @return: UpdateTaskOutputResponse """ UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.node_output): query['NodeOutput'] = request.node_output if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskOutput', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskOutputResponse(), self.call_api(params, req, runtime) ) def update_task_output(self, request): """ Only nodes of single-instance SQL assignment, script code, and ECS remote command have output variables. @param request: UpdateTaskOutputRequest @return: UpdateTaskOutputResponse """ runtime = util_models.RuntimeOptions() return self.update_task_output_with_options(request, runtime) def update_task_time_variables_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.node_id): query['NodeId'] = request.node_id if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.time_variables): query['TimeVariables'] = request.time_variables req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateTaskTimeVariables', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateTaskTimeVariablesResponse(), self.call_api(params, req, runtime) ) def update_task_time_variables(self, request): runtime = util_models.RuntimeOptions() return self.update_task_time_variables_with_options(request, runtime) def update_user_with_options(self, request, runtime): UtilClient.validate_model(request) query = {} if not UtilClient.is_unset(request.max_execute_count): query['MaxExecuteCount'] = request.max_execute_count if not UtilClient.is_unset(request.max_result_count): query['MaxResultCount'] = request.max_result_count if not UtilClient.is_unset(request.mobile): query['Mobile'] = request.mobile if not UtilClient.is_unset(request.role_names): query['RoleNames'] = request.role_names if not UtilClient.is_unset(request.tid): query['Tid'] = request.tid if not UtilClient.is_unset(request.uid): query['Uid'] = request.uid if not UtilClient.is_unset(request.user_nick): query['UserNick'] = request.user_nick req = open_api_models.OpenApiRequest( query=OpenApiUtilClient.query(query) ) params = open_api_models.Params( action='UpdateUser', version='2018-11-01', protocol='HTTPS', pathname='/', method='POST', auth_type='AK', style='RPC', req_body_type='formData', body_type='json' ) return TeaCore.from_map( dms_enterprise_20181101_models.UpdateUserResponse(), self.call_api(params, req, runtime) ) def update_user(self, request): runtime = util_models.RuntimeOptions() return self.update_user_with_options(request, runtime)

dms-enterprise-20181101/alibabacloud_dms_enterprise20181101/client.py (7,450 lines of code) (raw):