diff --git a/ucloud/services/udts/client.py b/ucloud/services/udts/client.py index 96f019a0..05f30d09 100644 --- a/ucloud/services/udts/client.py +++ b/ucloud/services/udts/client.py @@ -22,7 +22,7 @@ def check_udts_task( - **ProjectId** (str) - (Config) 项目ID。不填写为默认项目，子帐号必须填写。 请参考 `GetProjectList接口 `_ - **MaxRetryCount** (str) - (Required) 重试次数，最大为 5。 默认为0 - - **Name** (str) - (Required) 任务名称，长度不能超过 128 + - **Name** (str) - (Required) task 名称，长度不能超过 128 - **Type** (str) - (Required) 任务类型，值为 transfer 或 integration， transfer 时任务为 数据迁移，integration 时任务为 数据集成。 - **Query** (str) - 废弃 - **Source** (list) - 见 **CheckUDTSTaskParamSource** 模型定义 @@ -37,25 +37,6 @@ def check_udts_task( **Request Model** - **CheckUDTSTaskParamSourceMySQLNodeQueryData** - - **DBName** (str) - 数据集成时需要迁移的 DB 名 - - **NewDBName** (str) - 数据集成时迁移后的 DB 名 - - - **CheckUDTSTaskParamSourceMySQLNode** - - **DataRegion** (str) - 数据库地域，比如 cn-bj2 - - **Database** (str) - 需要迁移的 DB 名称 - - **Host** (str) - 源数据库地址， 比如 10.9.37.200 - - **Password** (str) - 源 MySQL 密码 - - **Port** (int) - 源 MySQL 端口，如 3306 - - **QueryData** (list) - 见 **CheckUDTSTaskParamSourceMySQLNodeQueryData** 模型定义 - - **SubnetId** (str) - 子网 ID，可以从 https://console.ucloud.cn/vpc/subnet，比如 subnet-2sloxs - - **SyncData** (dict) - 见 **CheckUDTSTaskParamSourceMySQLNodeSyncData** 模型定义 - - **Table** (str) - 需要迁移的 table 名 - - **User** (str) - 源 MySQL 用户名，如 root - - **VPCId** (str) - VPC ID, 可以从 https://console.ucloud.cn/vpc/vpc 获取，比如 uvnet-u0ecace - - **CheckUDTSTaskParamSourceMySQLNodeSyncData** - **BinlogGTID** (str) - 增量时需要指定的 binlog gtid，可以通过 show master status 获取，或者全量+增量任务会自动设置 - **BinlogName** (str) - 增量时需要指定的 binlog name，可以通过 show master status 获取，或者全量+增量任务会自动设置 @@ -63,12 +44,9 @@ def check_udts_task( - **ServerID** (int) - 增量时需要指定的 serverID，不能和现有的 slave 重复，预检查时会检查该值 - **CheckUDTSTaskParamSource** - - **DataType** (str) - 数据库类型，比如 mysql - - **Mode** (str) - 任务模式，值可以是 full, incremental, full+incremental, bidirectional - - **MySQLNode** (dict) - 见 **CheckUDTSTaskParamSourceMySQLNode** 模型定义 - - **NWType** (str) - 源网络类型，可以是 public,user,dedicated_line - - **ServiceType** (str) - 服务类型，值可以是 small、medium、large，分别对应 “基础版”、“轻量版” 和 “旗舰版” + **CheckUDTSTaskParamSourceMySQLNodeQueryData** + - **DBName** (str) - 数据集成时需要迁移的 DB 名 + - **NewDBName** (str) - 数据集成时迁移后的 DB 名 **CheckUDTSTaskParamTargetMySQLNode** @@ -81,17 +59,38 @@ def check_udts_task( - **VPCId** (str) - 目标数据库 VPC,比如 uvnet-1wz5rqte + **CheckUDTSTaskParamSourceMySQLNode** + - **DataRegion** (str) - 数据库地域，比如 cn-bj2 + - **Database** (str) - 需要迁移的 DB 名称 + - **Host** (str) - 源数据库地址， 比如 10.9.37.200 + - **Password** (str) - 源 MySQL 密码 + - **Port** (int) - 源 MySQL 端口，如 3306 + - **QueryData** (list) - 见 **CheckUDTSTaskParamSourceMySQLNodeQueryData** 模型定义 + - **SubnetId** (str) - 子网 ID + - **SyncData** (dict) - 见 **CheckUDTSTaskParamSourceMySQLNodeSyncData** 模型定义 + - **Table** (str) - 需要迁移的 table 名 + - **User** (str) - 源 MySQL 用户名，如 root + - **VPCId** (str) - VPC + + **CheckUDTSTaskParamTarget** - **DataType** (str) - 目标数据库类型，比如 mysql - **MySQLNode** (dict) - 见 **CheckUDTSTaskParamTargetMySQLNode** 模型定义 - **NWType** (str) - 目标 db 网络类型，目前进支持 user + **CheckUDTSTaskParamSource** + - **DataType** (str) - 数据库类型 + - **Mode** (str) - // 任务类型，值可以是 full, incremental, full+incremental, bidirectional + - **MySQLNode** (dict) - 见 **CheckUDTSTaskParamSourceMySQLNode** 模型定义 + - **NWType** (str) - 源网络类型，可以是 public,user,dedicated_line + + **Response Model** - **CheckUDTSTaskResult** - - **Source** (dict) - 见 **CheckResult** 模型定义 - - **Target** (dict) - 见 **CheckResult** 模型定义 + **CheckResultItem** + - **ErrMessage** (str) - + - **State** (str) - 状态 **CheckResult** @@ -100,9 +99,9 @@ def check_udts_task( - **Privileges** (dict) - 见 **CheckResultItem** 模型定义 - **CheckResultItem** - - **ErrMessage** (str) - - - **State** (str) - 状态 + **CheckUDTSTaskResult** + - **Source** (dict) - 见 **CheckResult** 模型定义 + - **Target** (dict) - 见 **CheckResult** 模型定义 """ @@ -124,13 +123,10 @@ def create_udts_task( **Request** - **ProjectId** (str) - (Config) 项目ID。不填写为默认项目，子帐号必须填写。 请参考 `GetProjectList接口 `_ - - **Name** (str) - (Required) 任务名称，长度不能超过 128 + - **Name** (str) - (Required) task 名称，长度不能超过 128 - **Type** (str) - (Required) 任务类型，transfer(数据传输) 或 integration(数据集成) - - **ChargeType** (str) - 付费方式, 枚举值为: Year, 按年付费; Month, 按月付费；Dynamic, 按需付费(需开启权限)；默认为按月付费 - - **CouponId** (str) - 代金券ID, 默认不使用 - **IsUnidirection** (str) - 暂时未使用该字段 - **MaxRetryCount** (str) - 重试次数，最大为 5。 默认为0 - - **Quantity** (int) - 购买时长, 默认: 1 - **Query** (str) - 暂时未使用该字段 - **Remark** (str) - 备注信息，长度不能大于 255 - **Source** (list) - 见 **CreateUDTSTaskParamSource** 模型定义 @@ -140,17 +136,9 @@ def create_udts_task( - **Data** (dict) - - **Message** (str) - 返回消息 - - **TaskId** (str) - 任务ID，目前用于控制台操作日志 **Request Model** - **CreateUDTSTaskParamSourceMySQLNodeQueryData** - - **DBName** (str) - 数据集成时需要迁移的 DB 名 - - **NewDBName** (str) - 数据集成时迁移后的 DB 名 - - **TableData** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNodeQueryDataTableData** 模型定义 - - **TableMaps** (list) - 见 **CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMaps** 模型定义 - - **CreateUDTSTaskParamSourceMySQLNodeQueryDataTableData** - **ExcludeTables** (bool) - 暂时未使用该字段 - **TableNames** (str) - 暂时未使用该字段 @@ -161,6 +149,20 @@ def create_udts_task( - **TableName** (str) - 数据集成时需要迁移的 Table 名 + **CreateUDTSTaskParamSourceMySQLNodeSyncData** + - **BinlogGTID** (str) - 增量时需要指定的 binlog gtid，可以通过 show master status 获取，或者全量+增量任务会自动设置 + - **BinlogName** (str) - 增量时需要指定的 binlog name，可以通过 show master status 获取，或者全量+增量任务会自动设置 + - **BinlogPos** (int) - 增量时需要指定的 binlog pos，可以通过 show master status 获取，或者全量+增量任务会自动设置 + - **ServerID** (int) - 增量时需要指定的 serverID，不能和现有的 slave 重复，预检查时会检查该值 + + + **CreateUDTSTaskParamSourceMySQLNodeQueryData** + - **DBName** (str) - 数据集成时需要迁移的 DB 名 + - **NewDBName** (str) - 数据集成时迁移后的 DB 名 + - **TableData** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNodeQueryDataTableData** 模型定义 + - **TableMaps** (list) - 见 **CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMaps** 模型定义 + + **CreateUDTSTaskParamSourceMySQLNode** - **DataRegion** (str) - 数据库地域，比如 cn-bj2 - **Database** (str) - 需要迁移的 DB 名称 @@ -170,28 +172,11 @@ def create_udts_task( - **Password** (str) - 源数据库密码 - **Port** (int) - 源数据库端口 - **QueryData** (list) - 见 **CreateUDTSTaskParamSourceMySQLNodeQueryData** 模型定义 - - **SSLSecurity** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNodeSSLSecurity** 模型定义 - - **SubnetId** (str) - 源数据库子网 ID，当网络类型为 user 时需要填写，可以从 https://console.ucloud.cn/vpc/subnet，比如 subnet-2sloxs + - **SubnetId** (str) - 源数据库子网 ID，当网络类型为 user 时需要填写 - **SyncData** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNodeSyncData** 模型定义 - **Table** (str) - 需要迁移的 table 名 - **User** (str) - 源数据库用户名 - - **VPCId** (str) - 源数据库 VPC ID，当网络类型为 user 时需要填写，可以从 https://console.ucloud.cn/vpc/vpc 获取，比如 uvnet-u0ecace - - - **CreateUDTSTaskParamSourceMySQLNodeSyncData** - - **BinlogGTID** (str) - 增量时需要指定的 binlog gtid，可以通过 show master status 获取，或者全量+增量任务会自动设置 - - **BinlogName** (str) - 增量时需要指定的 binlog name，可以通过 show master status 获取，或者全量+增量任务会自动设置 - - **BinlogPos** (int) - 增量时需要指定的 binlog pos，可以通过 show master status 获取，或者全量+增量任务会自动设置 - - **ServerID** (int) - 增量时需要指定的 serverID，不能和现有的 slave 重复，预检查时会检查该值 - - - **CreateUDTSTaskParamSource** - - **BandwidthLimit** (int) - 源端限速值，单位为 MB/s - - **DataType** (str) - 数据库类型，比如 mysql - - **Mode** (str) - 任务模式，值可以是 full, incremental, full+incremental, bidirectional - - **MySQLNode** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNode** 模型定义 - - **NWType** (str) - 源网络类型，可以是 public,user,dedicated_line - - **ServiceType** (str) - 服务类型，值可以是small、medium、large，分别对应“基础版”、“轻量版”和“旗舰版” + - **VPCId** (str) - 源数据库 VPC ID，当网络类型为 user 时需要填写 **CreateUDTSTaskParamTargetMySQLNode** @@ -205,6 +190,14 @@ def create_udts_task( - **VPCId** (str) - 目标数据库 VPC,比如 uvnet-1wz5rqte + **CreateUDTSTaskParamSource** + - **BandwidthLimit** (int) - 源端限速值，单位为 MB/s + - **DataType** (str) - 数据库类型，比如 mysql + - **Mode** (str) - 任务类型，值可以是 full, incremental, full+incremental, bidirectional + - **MySQLNode** (dict) - 见 **CreateUDTSTaskParamSourceMySQLNode** 模型定义 + - **NWType** (str) - 源网络类型，可以是 public,user,dedicated_line + + **CreateUDTSTaskParamTarget** - **BandwidthLimit** (str) - 目标端限速，单位为 MB/s - **DataType** (str) - 目标数据库类型，比如 mysql @@ -213,12 +206,6 @@ def create_udts_task( - **NWType** (str) - 目标 db 网络类型，目前仅支持 user - **CreateUDTSTaskParamSourceMySQLNodeSSLSecurity** - - **SSLCA** (str) - ca 证书，目前仅支持 pem 格式; 需要将文件内容 base64 - - **SSLCert** (str) - 客户端证书; 需要将文件内容 base64 - - **SSLKey** (str) - 客户端私钥， 需要将文件内容 base64 - - """ # build request d = { @@ -286,13 +273,11 @@ def get_udts_task_status( **Response Model** - **StatusData** - - **CurRetryCount** (int) - 当前失败重试次数 - - **FailedMessage** (str) - 当Status为Failed时, 显示失败原因 - - **MaxRetryCount** (int) - 用户设置的最大失败重试次数 - - **Progress** (dict) - 见 **Progress** 模型定义 - - **Status** (str) - 任务状态, 状态有 Created:已创建,Checking:检查中,Dumping:转储中,Loading:加载中,Syncing:同步中,Synced:已同步,Done:完成,Failed:失败,Stopping:停止中,Stopped:停止,RetryPending:重试等待中,Starting:启动中,FailedUnrecoverable:异常,StoppedUnrecoverable:异常,Success:成功,Started:已启动 - - **Sync** (dict) - 见 **SyncData** 模型定义 + **SyncData** + - **BinlogGTID** (str) - GTID + - **BinlogName** (str) - Binlog 文件名， 长度不超过128字符 + - **BinlogPos** (int) - Binlog Pos + - **ServerId** (int) - 分配给UDTS task的server ID, 必须在MySQL集群中唯一 **Progress** @@ -303,10 +288,13 @@ def get_udts_task_status( - **TotalDuration** (int) - 估算总耗时间（单位秒） - **SyncData** - - **BinlogGTID** (str) - GTID - - **BinlogName** (str) - Binlog 文件名， 长度不超过128字符 - - **BinlogPos** (int) - Binlog Pos + **StatusData** + - **CurRetryCount** (int) - 当前失败重试次数 + - **FailedMessage** (str) - 当Status为Failed时, 显示失败原因 + - **MaxRetryCount** (int) - 用户设置的最大失败重试次数 + - **Progress** (dict) - 见 **Progress** 模型定义 + - **Status** (str) - 任务状态, 状态有 Created:已创建,Checking:检查中,Dumping:转储中,Loading:加载中,Syncing:同步中,Synced:已同步,Done:完成,Failed:失败,Stopping:停止中,Stopped:停止,RetryPending:重试等待中,Starting:启动中,FailedUnrecoverable:异常,StoppedUnrecoverable:异常,Success:成功,Started:已启动 + - **Sync** (dict) - 见 **SyncData** 模型定义 """ @@ -327,7 +315,7 @@ def list_udts_task( **Request** - - **ProjectId** (str) - (Config) 项目ID。不填写为默认项目，子帐号必须填写。 请参考 `GetProjectList接口 `_ + - **ProjectId** (str) - (Config) 项目ID。不填写为默认项目，子帐号必须填写。 请参考 `GetProjectList接口 `_ - **Limit** (str) - 请求数量，默认为 20 - **Offset** (str) - 偏移量，默认为 0 - **Type** (str) - 任务类型 @@ -339,30 +327,25 @@ def list_udts_task( **Response Model** + **Progress** + - **CurCount** (int) - 已迁移条目数 + - **CurDuration** (int) - 已耗时间（单位秒） + - **Percentage** (float) - 完成进度 + - **TotalCount** (int) - 总条目数 + - **TotalDuration** (int) - 估算总耗时间（单位秒） + + **ListDataItem** - - **AutoRenew** (str) - 是否自动续费，枚举：Yes/ No - - **ChargeType** (str) - 资源付费类型，枚举：Dynamic/ Month/ Year/ Trial/ Day - **CreateTime** (int) - 创建时间 - **CurRetryCount** (int) - 当前失败重试次数 - - **ExpireTime** (int) - 资源有效期时间戳 - - **IsExpire** (str) - 资源是否过期，枚举：Yes/ No - **MaxRetryCount** (int) - 最大失败重试次数 - **Name** (str) - 任务名称 - **Progress** (dict) - 见 **Progress** 模型定义 - - **ServiceType** (str) - 服务类型， small, medium, large - **Status** (str) - 任务状态 - **TaskId** (str) - 任务 ID - **Type** (str) - 任务类型, full全量, incremental增量，full+incremental全量+增量。 - **Progress** - - **CurCount** (int) - 已迁移条目数 - - **CurDuration** (int) - 已耗时间（单位秒） - - **Percentage** (float) - 完成进度 - - **TotalCount** (int) - 总条目数 - - **TotalDuration** (int) - 估算总耗时间（单位秒） - - """ # build request d = { diff --git a/ucloud/services/udts/schemas/apis.py b/ucloud/services/udts/schemas/apis.py index 6534ad76..5a789397 100644 --- a/ucloud/services/udts/schemas/apis.py +++ b/ucloud/services/udts/schemas/apis.py @@ -15,6 +15,17 @@ """ +class CheckUDTSTaskParamSourceMySQLNodeSyncDataSchema(schema.RequestSchema): + """CheckUDTSTaskParamSourceMySQLNodeSyncData -""" + + fields = { + "BinlogGTID": fields.Str(required=False, dump_to="BinlogGTID"), + "BinlogName": fields.Str(required=False, dump_to="BinlogName"), + "BinlogPos": fields.Int(required=False, dump_to="BinlogPos"), + "ServerID": fields.Int(required=False, dump_to="ServerID"), + } + + class CheckUDTSTaskParamSourceMySQLNodeQueryDataSchema(schema.RequestSchema): """CheckUDTSTaskParamSourceMySQLNodeQueryData -""" @@ -24,6 +35,20 @@ class CheckUDTSTaskParamSourceMySQLNodeQueryDataSchema(schema.RequestSchema): } +class CheckUDTSTaskParamTargetMySQLNodeSchema(schema.RequestSchema): + """CheckUDTSTaskParamTargetMySQLNode -""" + + fields = { + "DataRegion": fields.Str(required=False, dump_to="DataRegion"), + "Host": fields.Str(required=False, dump_to="Host"), + "Password": fields.Str(required=False, dump_to="Password"), + "Port": fields.Int(required=False, dump_to="Port"), + "SubnetId": fields.Str(required=False, dump_to="SubnetId"), + "User": fields.Str(required=False, dump_to="User"), + "VPCId": fields.Str(required=False, dump_to="VPCId"), + } + + class CheckUDTSTaskParamSourceMySQLNodeSchema(schema.RequestSchema): """CheckUDTSTaskParamSourceMySQLNode -""" @@ -46,51 +71,25 @@ class CheckUDTSTaskParamSourceMySQLNodeSchema(schema.RequestSchema): } -class CheckUDTSTaskParamSourceMySQLNodeSyncDataSchema(schema.RequestSchema): - """CheckUDTSTaskParamSourceMySQLNodeSyncData -""" - - fields = { - "BinlogGTID": fields.Str(required=False, dump_to="BinlogGTID"), - "BinlogName": fields.Str(required=False, dump_to="BinlogName"), - "BinlogPos": fields.Int(required=False, dump_to="BinlogPos"), - "ServerID": fields.Int(required=False, dump_to="ServerID"), - } - - -class CheckUDTSTaskParamSourceSchema(schema.RequestSchema): - """CheckUDTSTaskParamSource -""" +class CheckUDTSTaskParamTargetSchema(schema.RequestSchema): + """CheckUDTSTaskParamTarget -""" fields = { "DataType": fields.Str(required=False, dump_to="DataType"), - "Mode": fields.Str(required=False, dump_to="Mode"), - "MySQLNode": CheckUDTSTaskParamSourceMySQLNodeSchema( + "MySQLNode": CheckUDTSTaskParamTargetMySQLNodeSchema( required=False, dump_to="MySQLNode" ), "NWType": fields.Str(required=False, dump_to="NWType"), - "ServiceType": fields.Str(required=True, dump_to="ServiceType"), } -class CheckUDTSTaskParamTargetMySQLNodeSchema(schema.RequestSchema): - """CheckUDTSTaskParamTargetMySQLNode -""" - - fields = { - "DataRegion": fields.Str(required=False, dump_to="DataRegion"), - "Host": fields.Str(required=False, dump_to="Host"), - "Password": fields.Str(required=False, dump_to="Password"), - "Port": fields.Int(required=False, dump_to="Port"), - "SubnetId": fields.Str(required=False, dump_to="SubnetId"), - "User": fields.Str(required=False, dump_to="User"), - "VPCId": fields.Str(required=False, dump_to="VPCId"), - } - - -class CheckUDTSTaskParamTargetSchema(schema.RequestSchema): - """CheckUDTSTaskParamTarget -""" +class CheckUDTSTaskParamSourceSchema(schema.RequestSchema): + """CheckUDTSTaskParamSource -""" fields = { "DataType": fields.Str(required=False, dump_to="DataType"), - "MySQLNode": CheckUDTSTaskParamTargetMySQLNodeSchema( + "Mode": fields.Str(required=False, dump_to="Mode"), + "MySQLNode": CheckUDTSTaskParamSourceMySQLNodeSchema( required=False, dump_to="MySQLNode" ), "NWType": fields.Str(required=False, dump_to="NWType"), @@ -131,21 +130,6 @@ class CheckUDTSTaskResponseSchema(schema.ResponseSchema): """ -class CreateUDTSTaskParamSourceMySQLNodeQueryDataSchema(schema.RequestSchema): - """CreateUDTSTaskParamSourceMySQLNodeQueryData -""" - - fields = { - "DBName": fields.Str(required=False, dump_to="DBName"), - "NewDBName": fields.Str(required=False, dump_to="NewDBName"), - "TableData": CreateUDTSTaskParamSourceMySQLNodeQueryDataTableDataSchema( - required=False, dump_to="TableData" - ), - "TableMaps": fields.List( - CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMapsSchema() - ), - } - - class CreateUDTSTaskParamSourceMySQLNodeQueryDataTableDataSchema( schema.RequestSchema ): @@ -168,6 +152,32 @@ class CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMapsSchema( } +class CreateUDTSTaskParamSourceMySQLNodeSyncDataSchema(schema.RequestSchema): + """CreateUDTSTaskParamSourceMySQLNodeSyncData -""" + + fields = { + "BinlogGTID": fields.Str(required=False, dump_to="BinlogGTID"), + "BinlogName": fields.Str(required=False, dump_to="BinlogName"), + "BinlogPos": fields.Int(required=False, dump_to="BinlogPos"), + "ServerID": fields.Int(required=False, dump_to="ServerID"), + } + + +class CreateUDTSTaskParamSourceMySQLNodeQueryDataSchema(schema.RequestSchema): + """CreateUDTSTaskParamSourceMySQLNodeQueryData -""" + + fields = { + "DBName": fields.Str(required=False, dump_to="DBName"), + "NewDBName": fields.Str(required=False, dump_to="NewDBName"), + "TableData": CreateUDTSTaskParamSourceMySQLNodeQueryDataTableDataSchema( + required=False, dump_to="TableData" + ), + "TableMaps": fields.List( + CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMapsSchema() + ), + } + + class CreateUDTSTaskParamSourceMySQLNodeSchema(schema.RequestSchema): """CreateUDTSTaskParamSourceMySQLNode -""" @@ -182,9 +192,6 @@ class CreateUDTSTaskParamSourceMySQLNodeSchema(schema.RequestSchema): "QueryData": fields.List( CreateUDTSTaskParamSourceMySQLNodeQueryDataSchema() ), - "SSLSecurity": CreateUDTSTaskParamSourceMySQLNodeSSLSecuritySchema( - required=False, dump_to="SSLSecurity" - ), "SubnetId": fields.Str(required=False, dump_to="SubnetId"), "SyncData": CreateUDTSTaskParamSourceMySQLNodeSyncDataSchema( required=False, dump_to="SyncData" @@ -195,14 +202,18 @@ class CreateUDTSTaskParamSourceMySQLNodeSchema(schema.RequestSchema): } -class CreateUDTSTaskParamSourceMySQLNodeSyncDataSchema(schema.RequestSchema): - """CreateUDTSTaskParamSourceMySQLNodeSyncData -""" +class CreateUDTSTaskParamTargetMySQLNodeSchema(schema.RequestSchema): + """CreateUDTSTaskParamTargetMySQLNode -""" fields = { - "BinlogGTID": fields.Str(required=False, dump_to="BinlogGTID"), - "BinlogName": fields.Str(required=False, dump_to="BinlogName"), - "BinlogPos": fields.Int(required=False, dump_to="BinlogPos"), - "ServerID": fields.Int(required=False, dump_to="ServerID"), + "DataRegion": fields.Str(required=False, dump_to="DataRegion"), + "Host": fields.Str(required=False, dump_to="Host"), + "NoBinlog": fields.Bool(required=False, dump_to="NoBinlog"), + "Password": fields.Str(required=False, dump_to="Password"), + "Port": fields.Int(required=False, dump_to="Port"), + "SubnetId": fields.Str(required=False, dump_to="SubnetId"), + "User": fields.Str(required=False, dump_to="User"), + "VPCId": fields.Str(required=False, dump_to="VPCId"), } @@ -217,22 +228,6 @@ class CreateUDTSTaskParamSourceSchema(schema.RequestSchema): required=False, dump_to="MySQLNode" ), "NWType": fields.Str(required=True, dump_to="NWType"), - "ServiceType": fields.Str(required=True, dump_to="ServiceType"), - } - - -class CreateUDTSTaskParamTargetMySQLNodeSchema(schema.RequestSchema): - """CreateUDTSTaskParamTargetMySQLNode -""" - - fields = { - "DataRegion": fields.Str(required=False, dump_to="DataRegion"), - "Host": fields.Str(required=False, dump_to="Host"), - "NoBinlog": fields.Bool(required=False, dump_to="NoBinlog"), - "Password": fields.Str(required=False, dump_to="Password"), - "Port": fields.Int(required=False, dump_to="Port"), - "SubnetId": fields.Str(required=False, dump_to="SubnetId"), - "User": fields.Str(required=False, dump_to="User"), - "VPCId": fields.Str(required=False, dump_to="VPCId"), } @@ -250,27 +245,14 @@ class CreateUDTSTaskParamTargetSchema(schema.RequestSchema): } -class CreateUDTSTaskParamSourceMySQLNodeSSLSecuritySchema(schema.RequestSchema): - """CreateUDTSTaskParamSourceMySQLNodeSSLSecurity -""" - - fields = { - "SSLCA": fields.Str(required=False, dump_to="SSLCA"), - "SSLCert": fields.Str(required=False, dump_to="SSLCert"), - "SSLKey": fields.Str(required=False, dump_to="SSLKey"), - } - - class CreateUDTSTaskRequestSchema(schema.RequestSchema): """CreateUDTSTask - 创建UDTS任务""" fields = { - "ChargeType": fields.Str(required=False, dump_to="ChargeType"), - "CouponId": fields.Str(required=False, dump_to="CouponId"), "IsUnidirection": fields.Str(required=False, dump_to="IsUnidirection"), "MaxRetryCount": fields.Str(required=False, dump_to="MaxRetryCount"), "Name": fields.Str(required=True, dump_to="Name"), "ProjectId": fields.Str(required=False, dump_to="ProjectId"), - "Quantity": fields.Int(required=False, dump_to="Quantity"), "Query": fields.Str(required=False, dump_to="Query"), "Remark": fields.Str(required=False, dump_to="Remark"), "Source": fields.List(CreateUDTSTaskParamSourceSchema()), @@ -287,7 +269,6 @@ class CreateUDTSTaskResponseSchema(schema.ResponseSchema): fields = { "Data": fields.Str(), "Message": fields.Str(required=True, load_from="Message"), - "TaskId": fields.Str(required=False, load_from="TaskId"), } diff --git a/ucloud/services/udts/schemas/models.py b/ucloud/services/udts/schemas/models.py index 1cc54038..031bfba2 100644 --- a/ucloud/services/udts/schemas/models.py +++ b/ucloud/services/udts/schemas/models.py @@ -42,6 +42,17 @@ class TaskHistoryItemSchema(schema.ResponseSchema): } +class SyncDataSchema(schema.ResponseSchema): + """SyncData - 增量同步数据""" + + fields = { + "BinlogGTID": fields.Str(required=False, load_from="BinlogGTID"), + "BinlogName": fields.Str(required=True, load_from="BinlogName"), + "BinlogPos": fields.Int(required=True, load_from="BinlogPos"), + "ServerId": fields.Int(required=True, load_from="ServerId"), + } + + class ProgressSchema(schema.ResponseSchema): """Progress - 进度信息""" @@ -54,19 +65,6 @@ class ProgressSchema(schema.ResponseSchema): } -class SyncDataSchema(schema.ResponseSchema): - """SyncData - 增量同步数据""" - - fields = { - "BinlogGTID": fields.Str(required=False, load_from="BinlogGTID"), - "BinlogName": fields.Str(required=False, load_from="BinlogName"), - "BinlogPos": fields.Int(required=False, load_from="BinlogPos"), - "ServerId": fields.Int( - required=True, load_from="ServerId" - ), # Deprecated, will be removed at 1.0 - } - - class StatusDataSchema(schema.ResponseSchema): """StatusData - 动态状态信息""" @@ -84,17 +82,12 @@ class ListDataItemSchema(schema.ResponseSchema): """ListDataItem - 返回列表的一个 Task 的信息""" fields = { - "AutoRenew": fields.Str(required=True, load_from="AutoRenew"), - "ChargeType": fields.Str(required=True, load_from="ChargeType"), "CreateTime": fields.Int(required=False, load_from="CreateTime"), "CurRetryCount": fields.Int(required=False, load_from="CurRetryCount"), - "ExpireTime": fields.Int(required=True, load_from="ExpireTime"), - "IsExpire": fields.Str(required=True, load_from="IsExpire"), "MaxRetryCount": fields.Int(required=False, load_from="MaxRetryCount"), - "Name": fields.Str(required=True, load_from="Name"), + "Name": fields.Str(required=False, load_from="Name"), "Progress": ProgressSchema(), - "ServiceType": fields.Str(required=True, load_from="ServiceType"), "Status": fields.Str(required=False, load_from="Status"), - "TaskId": fields.Str(required=True, load_from="TaskId"), - "Type": fields.Str(required=True, load_from="Type"), + "TaskId": fields.Str(required=False, load_from="TaskId"), + "Type": fields.Str(required=False, load_from="Type"), }