配置订阅通道

注意事项

• 在成功调用StartSubscriptionInstance接口启动订阅通道之前，您可以重复调用本接口修改订阅通道的配置。
• 如果传入了SubscriptionInstanceNetworkType参数则订阅通道被定义为新版，如果不传入该参数则订阅通道被定义为旧版。
  说明

  • 旧版订阅通道支持订阅RDS for MySQL、DRDS的数据。
  • 新版订阅通道支持订阅RDS for MySQL、POLARDB for MySQL和Oracle的数据。

请求参数

[
    {
        "DBName":"dtstestdata",
        "TableIncludes":[
            {
                "TableName":"customer"
            }
        ]
    }
]

返回参数

示例

    public void configureSubscriptionJob(String subscriptionJobId, String jobName, String region, String rdsInstanceId, String rdsUsername, String rdsPassword, String netType) throws Exception {
        ConfigureSubscriptionInstanceRequest request = new ConfigureSubscriptionInstanceRequest();

        // The subscription jobid created before
        request.setSubscriptionInstanceId(subscriptionJobId);

        // The subscription job name
        request.setSubscriptionInstanceName(jobName);

        request.setSourceEndpointInstanceType("RDS");
        request.setSourceEndpointUserName(rdsUsername);
        request.setSourceEndpointPassword(rdsPassword);
        request.setSourceEndpointInstanceID(rdsInstanceId);

        // Subscription DDL update
        request.setSubscriptionDataTypeDDL(Boolean.TRUE);
        // Subscription DML update
        request.setSubscriptionDataTypeDML(Boolean.TRUE);

        request.setSubscriptionObject("[{\"DBName\":\"portal_test\",\"NewDBName\":\"portal_test\",\"TableIncludes\":[{\"TableName\":\"test\",\"NewTableName\":\"test\"}]}]");

        request.setSubscriptionInstanceNetworkType(netType);

        ConfigureSubscriptionInstanceResponse response = client.getAcsResponse(request);
        if (!"true".equals(response.getSuccess())) {
            throw new Exception(response.getErrMessage() + " requestId=" + response.getErrCode());
        }
    }
			

错误码