ALIYUN::DTS::SubscriptionJob2 - 资源编排

ALIYUN::DTS::SubscriptionJob2类型用于配置订阅通道。

语法

{
  "Type": "ALIYUN::DTS::SubscriptionJob2",
  "Properties": {
    "Status": String,
    "Reserve": Map,
    "DelayPhone": String,
    "DedicatedClusterId": String,
    "ErrorNotice": Boolean,
    "DtsJobName": String,
    "DelayRuleTime": Integer,
    "DtsInstanceId": String,
    "DbList": Map,
    "DtsBisLabel": String,
    "SubscriptionDataType": Map,
    "Checkpoint": String,
    "DelayNotice": Boolean,
    "DtsJobId": String,
    "SubscriptionInstance": Map,
    "SourceEndpoint": Map,
    "ErrorPhone": String,
    "SrcPrimaryVswId": String,
    "MaxDu": Integer,
    "DestPrimaryVswId": String,
    "DestSecondaryVswId": String,
    "SrcSecondaryVswId": String,
    "MinDu": Integer,
    "ResourceGroupId": String
  }
}

属性

属性名称	类型	必须	允许更新	描述	约束
DtsJobName	String	是	是	订阅任务名称。	建议配置具有业务意义的名称（无唯一性要求），便于后续识别。
DbList	Map	是	是	订阅对象。	格式为JSON串。更多信息，请参见迁移、同步或订阅对象说明。
SourceEndpoint	Map	是	是	源实例配置。	更多信息，请参见SourceEndpoint属性。
SubscriptionInstance	Map	是	否	订阅实例配置。	更多信息，请参见SubscriptionInstance属性。
Checkpoint	String	否	否	增量数据迁移的启动位点或者同步位点。	格式为Unix时间戳，单位为秒。
DelayPhone	String	否	否	延迟报警的联系人手机号码。	多个手机号码以英文逗号（,）分隔。说明本参数目前只支持中国站，仅支持中国内地手机号码，且最多传入10个手机号码。国际站不支持手机告警，仅支持通过云监控平台为DTS任务设置报警规则。
DedicatedClusterId	String	否	否	DTS专属集群ID。	用于将订阅任务调度到指定的DTS专属集群上。
DelayNotice	Boolean	否	否	是否监控延迟状态。	取值： true：监控延迟状态。 false：非监控延迟状态。
DtsJobId	String	否	否	数据订阅任务ID。	无
DelayRuleTime	Integer	否	否	触发延迟报警的阈值。	单位为秒且需为整数，可根据业务需要设置阈值，建议设置10秒以上，避免因网络、数据库负载等原因导致的延迟波动。说明当DelayNotice取值为true时，本参数必须传入。
DestPrimaryVswId	String	否	否	VPC NAT目的端的主VSW ID。	无
DestSecondaryVswId	String	否	否	VPC NAT目标端的辅VSW ID。	无
DtsInstanceId	String	否	否	订阅实例ID。	无
DtsBisLabel	String	否	否	DTS实例的环境标签。	取值： normal：普通。 online：线上。
ErrorPhone	String	否	否	异常报警的联系人手机号码。	多个手机号码以英文逗号（,）分隔。说明本参数目前只支持中国站，仅支持中国内地手机号码，且最多传入10个手机号码。国际站不支持手机告警，仅支持通过云监控平台为DTS任务设置报警规则。
ErrorNotice	Boolean	否	否	是否监控异常状态。	取值： true：监控异常状态。 false：非监控异常状态。
Reserve	Map	否	否	DTS的保留参数。	通过指定此参数，可以向DTS任务添加源实例或目标实例的更多配置。例如，指定目的Kafka数据库的数据存储格式和CEN实例的ID。
ResourceGroupId	String	否	否	资源组的ID。	无
Status	String	否	是	资源的状态。	取值： Synchronizing：同步中。 Suspending：暂停中。 Stopping：已停止。
SubscriptionDataType	Map	否	是	订阅数据类型。	更多信息，请参见SubscriptionDataType属性。
SrcPrimaryVswId	String	否	否	VPC NAT源端的主VSW ID。	无
SrcSecondaryVswId	String	否	否	VPC NAT源端的辅VSW ID。	无
MaxDu	Integer	否	否	DU的上限。	只有serverless类型的实例支持此参数。
MinDu	Integer	否	否	DU的下限。	只有serverless类型的实例支持此参数。

SubscriptionDataType语法

"SubscriptionDataType": {
  "DML": Boolean,
  "DDL": Boolean
}

SubscriptionDataType属性

属性名称

类型

必须

允许更新

描述

约束

DML

Boolean

否

是

是否订阅DML类型的数据。

取值：

true（默认值）：订阅DML类型的数据。
false：不订阅DML类型的数据。

DDL

Boolean

否

是

是否订阅DDL类型的数据。

取值：

true（默认值）：订阅DDL类型的数据。
false：不订阅DDL类型的数据。

SubscriptionInstance语法

"SubscriptionInstance": {
  "VPCId": String,
  "NetworkType": String,
  "VSwitchId": String
}

SubscriptionInstance属性

属性名称	类型	必须	允许更新	描述	约束
NetworkType	String	是	否	订阅实例的网络类型。	取值：VPC，表示专有网络。如果传入了本参数，则订阅实例被定义为新版，您还需要正确设置SubscriptionInstance.VPCId和SubscriptionInstance.VSwitchID参数；如果不传入该参数，则订阅实例被定义为旧版。旧版订阅实例支持订阅自建MySQL、RDS for MySQL和DRDS的数据，新版订阅实例支持订阅自建MySQL、RDS for MySQL、PolarDB MySQL和Oracle的数据。
VPCId	String	否	否	订阅实例的专有网络ID。	当NetworkType取值为VPC时，本参数才可用且必须传入。
VSwitchId	String	否	否	订阅实例的虚拟交换机ID。	当NetworkType取值为VPC时，本参数才可用且必须传入。

SourceEndpoint语法

"SourceEndpoint": {
  "OracleSID": String,
  "UserName": String,
  "InstanceID": String,
  "IP": String,
  "Port": String,
  "VSwitchID": String,
  "DatabaseName": String,
  "EngineName": String,
  "Role": String,
  "OwnerID": String,
  "Region": String,
  "InstanceType": String,
  "Password": String
}

SourceEndpoint属性

属性名称	类型	必须	允许更新	描述	约束
OracleSID	String	否	否	Oracle数据库的SID信息。	当EngineName取值为Oracle，且Oracle数据库为非RAC实例时，本参数才可用且必须传入。
UserName	String	否	否	源库的数据库账号。	迁移不同的数据库所需的权限有所差异，请参见迁移方案概览中对应的配置案例。
InstanceID	String	否	否	源库的实例ID。	取值：当SourceEndpoint.InstanceType取值为RDS、ECS、Express、MongoDB、PolarDB或PolarDB_o时，本参数才可用且必须传入对应的实例ID（例如取值为ECS，则本参数传入ECS实例的ID）。当SourceEndpoint.InstanceType取值为Express时，本参数传入VPC ID（即专有网络ID）。
IP	String	否	否	源库的连接地址。	当InstanceType取值为LocalInstance或Express时，本参数才可用且必须传入。
Port	String	否	否	源库的服务端口。	当InstanceType取值为ECS、LocalInstance或Express时，本参数才可用且必须传入。
VSwitchID	String	否	否	用于数据传输链路的vSwitch的ID。	无
DatabaseName	String	否	否	待迁移的数据库名称或鉴权数据库名称。	当SourceEndpoint.EngineName取值为PostgreSQL或MongoDB时，本参数才可用且必须传入。当SourceEndpoint.EngineName取值为PostgreSQL时，传入待迁移的数据库名称；取值为MongoDB时，传入数据库账号的鉴权数据库名称。
EngineName	String	否	否	源库的数据库类型。	取值： MySQL TiDB SQLServer PostgreSQL Oracle MongoDB Redis PolarDB polardb_pg 说明当InstanceType取值为RDS、PolarDB、ECS、LocalInstance或Express时，本参数才可用且必须传入。
Role	String	否	否	指定源实例的授权角色。	当源实例与目标实例所属阿里云账号不同时，需传入该参数，来指定源实例的授权角色，以允许目标实例阿里云账号访问源实例的实例信息。说明角色所需的权限及授权方式，请参见跨阿里云账号任务如何配置RAM授权。
OwnerID	String	否	否	源实例所属的阿里云账号ID。	仅在配置跨阿里云账号的数据迁移时本参数才可用，且必须传入。
Region	String	否	否	源库所属的地域ID。	当InstanceType取值为LocalInstance时，您可以传入cn-hangzhou或者离自建数据库地理距离最近的地域ID，详情请参见支持的地域列表。
InstanceType	String	否	否	源库的实例类型。	取值： RDS：阿里云RDS实例。 ECS：ECS上的自建数据库。 LocalInstance：有公网IP的自建数据库。 Express：通过专线、VPN网关、智能接入网关接入的自建数据库。 dg：通过数据库网关DG接入的自建数据库。 cen：通过云企业网CEN接入的自建数据库。 MongoDB：阿里云MongoDB实例。 PolarDB：阿里云PolarDB MySQL、PolarDB PostgreSQL。 PolarDB_o：阿里云PolarDB O引擎集群。
Password	String	否	是	源库数据库账号的密码。	无

返回值

Fn::GetAtt

DtsJobId：任务ID。
DtsJobName：DTS作业的名称。
DtsInstanceId：DTS实例的ID。

示例

YAML

ROSTemplateFormatVersion: '2015-09-01'
Parameters:
  Checkpoint:
    Description:
      en: The start offset of incremental data migration or synchronization. This
        value is a UNIX timestamp representing the number of seconds that have elapsed
        since January 1, 1970, 00:00:00 UTC.
    Type: String
  DbList:
    Description:
      en: The objects for which you want to track data changes.
    Type: Json
  DedicatedClusterId:
    Description:
      en: The ID of the DTS dedicated cluster on which the task runs.
    Type: String
  DelayNotice:
    Description:
      en: 'Specifies whether to monitor the task latency. Valid values: **true** and
        **false**'
    Type: Boolean
  DelayPhone:
    Description:
      en: 'The mobile numbers that receive latency-related alerts. Separate multiple
        mobile numbers with commas (,).

        **Note**: This parameter is available only for users of the China site (aliyun.com).
        Only mobile numbers in the Chinese mainland are supported. You can specify
        up to 10 mobile numbers. Users of the international site (alibabacloud.com)
        cannot receive alerts by using mobile numbers, but can configure alert rules
        for DTS tasks in the CloudMonitor console.'
    Type: String
  DelayRuleTime:
    Description:
      en: 'The threshold for latency alerts. Unit: seconds. You can set the threshold
        based on your business requirements. To prevent jitters caused by network
        and database overloads, we recommend that you set the threshold to more than
        10 seconds.'
    Type: Number
  DtsBisLabel:
    Description:
      en: 'The environment tag of the DTS instance. Valid values: **normal** and **online**.'
    Type: String
  DtsInstanceId:
    Description:
      en: The ID of the DTS instance.
    Type: String
  DtsJobId:
    Description:
      en: The ID of the DTS task.
    Type: String
  DtsJobName:
    Description:
      en: The name of the DTS instance.
    Type: String
  ErrorNotice:
    Description:
      en: 'Specifies whether to monitor the task status. Valid values: **true** and
        **false**.'
    Type: Boolean
  ErrorPhone:
    Description:
      en: 'The mobile numbers that receive status-related alerts. Separate multiple
        mobile numbers with commas (,).

        **Note**: This parameter is available only for users of the China site (aliyun.com).
        Only mobile numbers in the Chinese mainland are supported. You can specify
        up to 10 mobile numbers. Users of the international site (alibabacloud.com)
        cannot receive alerts by using mobile numbers, but can configure alert rules
        for DTS tasks in the CloudMonitor console.'
    Type: String
  Reserve:
    Description:
      en: The reserved parameter of DTS. You can specify this parameter to add more
        configurations of the source or destination instance to the DTS task. For
        example, you can specify the data storage format of the destination Kafka
        database and the ID of the CEN instance.
    Type: Json
  SourceEndpoint:
    AssociationPropertyMetadata:
      Parameters:
        DatabaseName:
          Description:
            en: 'The name of the database which contains the objects to be migrated
              in the source instance.

              **Note**: This parameter is required only when the source instance is
              a PolarDB for PostgreSQL cluster (compatible with Oracle), a PostgreSQL
              database, or a MongoDB database.'
          Type: String
        EngineName:
          Description:
            en: 'The engine of the source database. Valid values: **MySQL**, **PostgreSQL**,
              and **Oracle**.

              **Note**: If the source database is a self-managed database, you must
              specify this parameter.'
          Type: String
        IP:
          Description:
            en: "The IP address of the source instance. \n**Note**: This parameter\
              \ is required only when **InstanceType** is set to **OTHER**, **EXPRESS**,\
              \ **DG**, or **CEN**."
          Type: String
        InstanceID:
          Description:
            en: "The ID of the source instance. If the source instance is an Alibaba\
              \ Cloud database instance, you must specify the ID of the database instance.\
              \ For example, \n- If the source instance is an ApsaraDB RDS for MySQL\
              \ instance, you must specify the ID of the ApsaraDB RDS for MySQL instance.\
              \ \n- If the source instance is a self-managed database, the value of\
              \ this parameter varies with the value of SourceEndpointInstanceType.\n\
              - If InstanceType is set to ECS, you must specify the ID of the ECS\
              \ instance.\n- If InstanceType is set to DG, you must specify the ID\
              \ of the database gateway.\n- If InstanceType is set to EXPRESS or CEN,\
              \ you must specify the ID of the VPC that is connected to the source\
              \ instance.\n**Note**: If DestinationEndpointInstanceType is set to\
              \ CEN, you must also specify the ID of the CEN instance in the Reserve\
              \ parameter."
          Type: String
        InstanceType:
          Description:
            en: 'The type of the source instance. Valid values:

              - **RDS**: ApsaraDB RDS for MySQL instance

              - **PolarDB**: PolarDB for MySQL cluster

              - **DRDS**: PolarDB-X 1.0 instance

              - **LocalInstance**: self-managed database with a public IP address

              - **ECS**: self-managed database hosted on an Elastic Compute Service
              (ECS) instance

              - **Express**: self-managed database connected over Express Connect

              - **CEN**: self-managed database connected over Cloud Enterprise Network
              (CEN)

              - **dg**: self-managed database connected over Database Gateway'
          Type: String
        OracleSID:
          Description:
            en: 'The system ID (SID) of the Oracle database.

              **Note**: This parameter is required only when **EngineName** is set
              to **ORACLE** and the Oracle database is deployed in an architecture
              that is not a Real Application Cluster (RAC).'
          Type: String
        OwnerID:
          Description:
            en: 'The ID of the Alibaba Cloud account to which the source database
              belongs.

              **Note**: You can specify this parameter to migrate or synchronize data
              across different Alibaba Cloud accounts. In this case, you must specify
              **Role**.'
          Type: String
        Password:
          Description:
            en: The password of the source database account.
          Type: String
        Port:
          Description:
            en: 'The port number of the source instance.

              **Note**: This parameter is required only when the source instance is
              a self-managed database.'
          Type: String
        Region:
          Description:
            en: 'The ID of the region in which the source instance resides.

              **Note**: If the source instance is an Alibaba Cloud database instance,
              this parameter is required.'
          Type: String
        Role:
          Description:
            en: 'The name of the Resource Access Management (RAM) role configured
              for the Alibaba Cloud account that owns the source instance.

              **Note**: This parameter is required when you migrate or synchronize
              data across different Alibaba Cloud accounts.'
          Type: String
        UserName:
          Description:
            en: 'The database account of the source database.

              **Note**: In most cases, this parameter is required. The permissions
              that are required for the database account vary with the migration or
              synchronization scenario.'
          Type: String
        VSwitchID:
          Description:
            en: The ID of the vSwitch used for the data shipping link.
          Type: String
    Description:
      en: Source instance configuration.
    Type: Json
  Status:
    AllowedValues:
    - Subscribing
    - Suspending
    - Stopping
    Description:
      en: 'The status of the resource. Valid values:

        - **Subscribing**: Start the task.

        - **Suspending**: Suspend the task.

        - **Stopping**: Stop the task.'
    Type: String
  SubscriptionDataType:
    AssociationPropertyMetadata:
      Parameters:
        DDL:
          Description:
            en: 'Specifies whether to track DDL statements. Default value: true. Valid
              values:

              - **true**: tracks DDL statements.

              - **false**: does not track DDL statements.'
          Type: Boolean
        DML:
          Description:
            en: 'Specifies whether to track DML statements. Default value: true. Valid
              values:

              - **true**: tracks DML statements.

              - **false**: does not track DML statements.'
          Type: Boolean
    Description:
      en: Subscription data type.
    Type: Json
  SubscriptionInstance:
    AssociationPropertyMetadata:
      Parameters:
        NetworkType:
          Description:
            en: 'The network type of the change tracking task. Set the value to **vpc**.
              A value of vpc indicates the Virtual Private Cloud (VPC) network type.**Note**:

              - To use the new version of the change tracking feature, you must specify
              **NetworkType**. You must also specify **VPCId** and **VSwitchID**.
              If you do not specify **NetworkType**, the previous version of the change
              tracking feature is used.

              - The previous version of the change tracking feature supports self-managed
              MySQL databases, ApsaraDB RDS for MySQL instances, and PolarDB-X 1.0
              instances. The new version of the change tracking feature supports self-managed
              MySQL databases, ApsaraDB RDS for MySQL instances, PolarDB for MySQL
              clusters, and Oracle databases.'
          Type: String
        VPCId:
          Description:
            en: 'The ID of the VPC in which the change tracking instance is deployed.

              **Note**: This parameter takes effect and is required only when **NetworkType**
              is set to **vpc**.'
          Type: String
        VSwitchId:
          AssociationProperty: ALIYUN::VPC::VSwitch::VSwitchId
          AssociationPropertyMetadata:
            VpcId: ${.VpcId}
            ZoneId: ${.ZoneId}
          Description:
            en: 'The ID of the vSwitch in the specified VPC.

              **Note**: This parameter takes effect and is required only when **NetworkType**
              is set to **vpc**.'
          Type: String
    Description:
      en: Subscription instance configuration.
    Type: Json
Resources:
  SubscriptionJob:
    Properties:
      Checkpoint:
        Ref: Checkpoint
      DbList:
        Ref: DbList
      DedicatedClusterId:
        Ref: DedicatedClusterId
      DelayNotice:
        Ref: DelayNotice
      DelayPhone:
        Ref: DelayPhone
      DelayRuleTime:
        Ref: DelayRuleTime
      DtsBisLabel:
        Ref: DtsBisLabel
      DtsInstanceId:
        Ref: DtsInstanceId
      DtsJobId:
        Ref: DtsJobId
      DtsJobName:
        Ref: DtsJobName
      ErrorNotice:
        Ref: ErrorNotice
      ErrorPhone:
        Ref: ErrorPhone
      Reserve:
        Ref: Reserve
      SourceEndpoint:
        Ref: SourceEndpoint
      Status:
        Ref: Status
      SubscriptionDataType:
        Ref: SubscriptionDataType
      SubscriptionInstance:
        Ref: SubscriptionInstance
    Type: ALIYUN::DTS::SubscriptionJob2
Outputs:
  DtsInstanceId:
    Description: The ID of the DTS instance.
    Value:
      Fn::GetAtt:
      - SubscriptionJob
      - DtsInstanceId
  DtsJobId:
    Description: The ID of the task.
    Value:
      Fn::GetAtt:
      - SubscriptionJob
      - DtsJobId
  DtsJobName:
    Description: The name of the DTS job.
    Value:
      Fn::GetAtt:
      - SubscriptionJob
      - DtsJobName

JSON

{
  "ROSTemplateFormatVersion": "2015-09-01",
  "Parameters": {
    "Status": {
      "Type": "String",
      "Description": {
        "en": "The status of the resource. Valid values:\n- **Subscribing**: Start the task.\n- **Suspending**: Suspend the task.\n- **Stopping**: Stop the task."
      },
      "AllowedValues": [
        "Subscribing",
        "Suspending",
        "Stopping"
      ]
    },
    "Reserve": {
      "Type": "Json",
      "Description": {
        "en": "The reserved parameter of DTS. You can specify this parameter to add more configurations of the source or destination instance to the DTS task. For example, you can specify the data storage format of the destination Kafka database and the ID of the CEN instance."
      }
    },
    "DedicatedClusterId": {
      "Type": "String",
      "Description": {
        "en": "The ID of the DTS dedicated cluster on which the task runs."
      }
    },
    "DelayPhone": {
      "Type": "String",
      "Description": {
        "en": "The mobile numbers that receive latency-related alerts. Separate multiple mobile numbers with commas (,).\n**Note**: This parameter is available only for users of the China site (aliyun.com). Only mobile numbers in the Chinese mainland are supported. You can specify up to 10 mobile numbers. Users of the international site (alibabacloud.com) cannot receive alerts by using mobile numbers, but can configure alert rules for DTS tasks in the CloudMonitor console."
      }
    },
    "ErrorNotice": {
      "Type": "Boolean",
      "Description": {
        "en": "Specifies whether to monitor the task status. Valid values: **true** and **false**."
      }
    },
    "DtsJobName": {
      "Type": "String",
      "Description": {
        "en": "The name of the DTS instance."
      }
    },
    "DelayRuleTime": {
      "Type": "Number",
      "Description": {
        "en": "The threshold for latency alerts. Unit: seconds. You can set the threshold based on your business requirements. To prevent jitters caused by network and database overloads, we recommend that you set the threshold to more than 10 seconds."
      }
    },
    "DtsInstanceId": {
      "Type": "String",
      "Description": {
        "en": "The ID of the DTS instance."
      }
    },
    "DbList": {
      "Type": "Json",
      "Description": {
        "en": "The objects for which you want to track data changes."
      }
    },
    "DtsBisLabel": {
      "Type": "String",
      "Description": {
        "en": "The environment tag of the DTS instance. Valid values: **normal** and **online**."
      }
    },
    "SubscriptionDataType": {
      "AssociationPropertyMetadata": {
        "Parameters": {
          "DML": {
            "Type": "Boolean",
            "Description": {
              "en": "Specifies whether to track DML statements. Default value: true. Valid values:\n- **true**: tracks DML statements.\n- **false**: does not track DML statements."
            }
          },
          "DDL": {
            "Type": "Boolean",
            "Description": {
              "en": "Specifies whether to track DDL statements. Default value: true. Valid values:\n- **true**: tracks DDL statements.\n- **false**: does not track DDL statements."
            }
          }
        }
      },
      "Type": "Json",
      "Description": {
        "en": "Subscription data type."
      }
    },
    "Checkpoint": {
      "Type": "String",
      "Description": {
        "en": "The start offset of incremental data migration or synchronization. This value is a UNIX timestamp representing the number of seconds that have elapsed since January 1, 1970, 00:00:00 UTC."
      }
    },
    "DelayNotice": {
      "Type": "Boolean",
      "Description": {
        "en": "Specifies whether to monitor the task latency. Valid values: **true** and **false**"
      }
    },
    "DtsJobId": {
      "Type": "String",
      "Description": {
        "en": "The ID of the DTS task."
      }
    },
    "SubscriptionInstance": {
      "AssociationPropertyMetadata": {
        "Parameters": {
          "VPCId": {
            "Type": "String",
            "Description": {
              "en": "The ID of the VPC in which the change tracking instance is deployed.\n**Note**: This parameter takes effect and is required only when **NetworkType** is set to **vpc**."
            }
          },
          "NetworkType": {
            "Type": "String",
            "Description": {
              "en": "The network type of the change tracking task. Set the value to **vpc**. A value of vpc indicates the Virtual Private Cloud (VPC) network type.**Note**:\n- To use the new version of the change tracking feature, you must specify **NetworkType**. You must also specify **VPCId** and **VSwitchID**. If you do not specify **NetworkType**, the previous version of the change tracking feature is used.\n- The previous version of the change tracking feature supports self-managed MySQL databases, ApsaraDB RDS for MySQL instances, and PolarDB-X 1.0 instances. The new version of the change tracking feature supports self-managed MySQL databases, ApsaraDB RDS for MySQL instances, PolarDB for MySQL clusters, and Oracle databases."
            }
          },
          "VSwitchId": {
            "AssociationPropertyMetadata": {
              "VpcId": "${.VpcId}",
              "ZoneId": "${.ZoneId}"
            },
            "AssociationProperty": "ALIYUN::VPC::VSwitch::VSwitchId",
            "Type": "String",
            "Description": {
              "en": "The ID of the vSwitch in the specified VPC.\n**Note**: This parameter takes effect and is required only when **NetworkType** is set to **vpc**."
            }
          }
        }
      },
      "Type": "Json",
      "Description": {
        "en": "Subscription instance configuration."
      }
    },
    "SourceEndpoint": {
      "AssociationPropertyMetadata": {
        "Parameters": {
          "OracleSID": {
            "Type": "String",
            "Description": {
              "en": "The system ID (SID) of the Oracle database.\n**Note**: This parameter is required only when **EngineName** is set to **ORACLE** and the Oracle database is deployed in an architecture that is not a Real Application Cluster (RAC)."
            }
          },
          "UserName": {
            "Type": "String",
            "Description": {
              "en": "The database account of the source database.\n**Note**: In most cases, this parameter is required. The permissions that are required for the database account vary with the migration or synchronization scenario."
            }
          },
          "InstanceID": {
            "Type": "String",
            "Description": {
              "en": "The ID of the source instance. If the source instance is an Alibaba Cloud database instance, you must specify the ID of the database instance. For example, \n- If the source instance is an ApsaraDB RDS for MySQL instance, you must specify the ID of the ApsaraDB RDS for MySQL instance. \n- If the source instance is a self-managed database, the value of this parameter varies with the value of SourceEndpointInstanceType.\n- If InstanceType is set to ECS, you must specify the ID of the ECS instance.\n- If InstanceType is set to DG, you must specify the ID of the database gateway.\n- If InstanceType is set to EXPRESS or CEN, you must specify the ID of the VPC that is connected to the source instance.\n**Note**: If DestinationEndpointInstanceType is set to CEN, you must also specify the ID of the CEN instance in the Reserve parameter."
            }
          },
          "IP": {
            "Type": "String",
            "Description": {
              "en": "The IP address of the source instance. \n**Note**: This parameter is required only when **InstanceType** is set to **OTHER**, **EXPRESS**, **DG**, or **CEN**."
            }
          },
          "Port": {
            "Type": "String",
            "Description": {
              "en": "The port number of the source instance.\n**Note**: This parameter is required only when the source instance is a self-managed database."
            }
          },
          "VSwitchID": {
            "Type": "String",
            "Description": {
              "en": "The ID of the vSwitch used for the data shipping link."
            }
          },
          "DatabaseName": {
            "Type": "String",
            "Description": {
              "en": "The name of the database which contains the objects to be migrated in the source instance.\n**Note**: This parameter is required only when the source instance is a PolarDB for PostgreSQL cluster (compatible with Oracle), a PostgreSQL database, or a MongoDB database."
            }
          },
          "EngineName": {
            "Type": "String",
            "Description": {
              "en": "The engine of the source database. Valid values: **MySQL**, **PostgreSQL**, and **Oracle**.\n**Note**: If the source database is a self-managed database, you must specify this parameter."
            }
          },
          "Role": {
            "Type": "String",
            "Description": {
              "en": "The name of the Resource Access Management (RAM) role configured for the Alibaba Cloud account that owns the source instance.\n**Note**: This parameter is required when you migrate or synchronize data across different Alibaba Cloud accounts."
            }
          },
          "OwnerID": {
            "Type": "String",
            "Description": {
              "en": "The ID of the Alibaba Cloud account to which the source database belongs.\n**Note**: You can specify this parameter to migrate or synchronize data across different Alibaba Cloud accounts. In this case, you must specify **Role**."
            }
          },
          "Region": {
            "Type": "String",
            "Description": {
              "en": "The ID of the region in which the source instance resides.\n**Note**: If the source instance is an Alibaba Cloud database instance, this parameter is required."
            }
          },
          "InstanceType": {
            "Type": "String",
            "Description": {
              "en": "The type of the source instance. Valid values:\n- **RDS**: ApsaraDB RDS for MySQL instance\n- **PolarDB**: PolarDB for MySQL cluster\n- **DRDS**: PolarDB-X 1.0 instance\n- **LocalInstance**: self-managed database with a public IP address\n- **ECS**: self-managed database hosted on an Elastic Compute Service (ECS) instance\n- **Express**: self-managed database connected over Express Connect\n- **CEN**: self-managed database connected over Cloud Enterprise Network (CEN)\n- **dg**: self-managed database connected over Database Gateway"
            }
          },
          "Password": {
            "Type": "String",
            "Description": {
              "en": "The password of the source database account."
            }
          }
        }
      },
      "Type": "Json",
      "Description": {
        "en": "Source instance configuration."
      }
    },
    "ErrorPhone": {
      "Type": "String",
      "Description": {
        "en": "The mobile numbers that receive status-related alerts. Separate multiple mobile numbers with commas (,).\n**Note**: This parameter is available only for users of the China site (aliyun.com). Only mobile numbers in the Chinese mainland are supported. You can specify up to 10 mobile numbers. Users of the international site (alibabacloud.com) cannot receive alerts by using mobile numbers, but can configure alert rules for DTS tasks in the CloudMonitor console."
      }
    }
  },
  "Resources": {
    "SubscriptionJob": {
      "Type": "ALIYUN::DTS::SubscriptionJob2",
      "Properties": {
        "Status": {
          "Ref": "Status"
        },
        "Reserve": {
          "Ref": "Reserve"
        },
        "DedicatedClusterId": {
          "Ref": "DedicatedClusterId"
        },
        "DelayPhone": {
          "Ref": "DelayPhone"
        },
        "ErrorNotice": {
          "Ref": "ErrorNotice"
        },
        "DtsJobName": {
          "Ref": "DtsJobName"
        },
        "DelayRuleTime": {
          "Ref": "DelayRuleTime"
        },
        "DtsInstanceId": {
          "Ref": "DtsInstanceId"
        },
        "DbList": {
          "Ref": "DbList"
        },
        "DtsBisLabel": {
          "Ref": "DtsBisLabel"
        },
        "SubscriptionDataType": {
          "Ref": "SubscriptionDataType"
        },
        "Checkpoint": {
          "Ref": "Checkpoint"
        },
        "DelayNotice": {
          "Ref": "DelayNotice"
        },
        "DtsJobId": {
          "Ref": "DtsJobId"
        },
        "SubscriptionInstance": {
          "Ref": "SubscriptionInstance"
        },
        "SourceEndpoint": {
          "Ref": "SourceEndpoint"
        },
        "ErrorPhone": {
          "Ref": "ErrorPhone"
        }
      }
    }
  },
  "Outputs": {
    "DtsJobId": {
      "Description": "The ID of the task.",
      "Value": {
        "Fn::GetAtt": [
          "SubscriptionJob",
          "DtsJobId"
        ]
      }
    },
    "DtsJobName": {
      "Description": "The name of the DTS job.",
      "Value": {
        "Fn::GetAtt": [
          "SubscriptionJob",
          "DtsJobName"
        ]
      }
    },
    "DtsInstanceId": {
      "Description": "The ID of the DTS instance.",
      "Value": {
        "Fn::GetAtt": [
          "SubscriptionJob",
          "DtsInstanceId"
        ]
      }
    }
  }
}