Skip to content

SubscriptionJob2Props

Properties for defining a SubscriptionJob2.

See https://www.alibabacloud.com/help/ros/developer-reference/aliyun-dts-subscriptionjob2

Initializer 

import ros_cdk_dts
ros_cdk_dts.SubscriptionJob2Props(
  db_list: typing.Union[IResolvable, typing.Mapping[typing.Any]],
  dts_job_name: typing.Union[str, IResolvable],
  source_endpoint: typing.Union[IResolvable, SourceEndpointProperty],
  subscription_instance: typing.Union[IResolvable, SubscriptionInstanceProperty],
  checkpoint: typing.Union[str, IResolvable] = None,
  dedicated_cluster_id: typing.Union[str, IResolvable] = None,
  delay_notice: typing.Union[bool, IResolvable] = None,
  delay_phone: typing.Union[str, IResolvable] = None,
  delay_rule_time: typing.Union[typing.Union[int, float], IResolvable] = None,
  dts_bis_label: typing.Union[str, IResolvable] = None,
  dts_instance_id: typing.Union[str, IResolvable] = None,
  dts_job_id: typing.Union[str, IResolvable] = None,
  error_notice: typing.Union[bool, IResolvable] = None,
  error_phone: typing.Union[str, IResolvable] = None,
  reserve: typing.Union[IResolvable, typing.Mapping[typing.Any]] = None,
  status: typing.Union[str, IResolvable] = None,
  subscription_data_type: typing.Union[IResolvable, SubscriptionDataTypeProperty] = None
)

Properties

Name Type Description
db_list typing.Union[ros_cdk_core.IResolvable, typing.Mapping[typing.Any]] Property dbList: The objects for which you want to track data changes.
dts_job_name typing.Union[str, ros_cdk_core.IResolvable] Property dtsJobName: The name of the DTS instance.
source_endpoint typing.Union[ros_cdk_core.IResolvable, SourceEndpointProperty] Property sourceEndpoint: Source instance configuration.
subscription_instance typing.Union[ros_cdk_core.IResolvable, SubscriptionInstanceProperty] Property subscriptionInstance: Subscription instance configuration.
checkpoint typing.Union[str, ros_cdk_core.IResolvable] Property checkpoint: The start offset of incremental data migration or synchronization.
dedicated_cluster_id typing.Union[str, ros_cdk_core.IResolvable] Property dedicatedClusterId: The ID of the DTS dedicated cluster on which the task runs.
delay_notice typing.Union[bool, ros_cdk_core.IResolvable] Property delayNotice: Specifies whether to monitor the task latency.
delay_phone typing.Union[str, ros_cdk_core.IResolvable] Property delayPhone: The mobile numbers that receive latency-related alerts.
delay_rule_time typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable] Property delayRuleTime: The threshold for latency alerts.
dts_bis_label typing.Union[str, ros_cdk_core.IResolvable] Property dtsBisLabel: The environment tag of the DTS instance.
dts_instance_id typing.Union[str, ros_cdk_core.IResolvable] Property dtsInstanceId: The ID of the DTS instance.
dts_job_id typing.Union[str, ros_cdk_core.IResolvable] Property dtsJobId: The ID of the DTS task.
error_notice typing.Union[bool, ros_cdk_core.IResolvable] Property errorNotice: Specifies whether to monitor the task status.
error_phone typing.Union[str, ros_cdk_core.IResolvable] Property errorPhone: The mobile numbers that receive status-related alerts.
reserve typing.Union[ros_cdk_core.IResolvable, typing.Mapping[typing.Any]] Property reserve: The reserved parameter of DTS.
status typing.Union[str, ros_cdk_core.IResolvable] Property status: The status of the resource.
subscription_data_type typing.Union[ros_cdk_core.IResolvable, SubscriptionDataTypeProperty] Property subscriptionDataType: Subscription data type.

db_listRequired 

db_list: typing.Union[IResolvable, typing.Mapping[typing.Any]]
  • Type: typing.Union[ros_cdk_core.IResolvable, typing.Mapping[typing.Any]]

Property dbList: The objects for which you want to track data changes.

dts_job_nameRequired 

dts_job_name: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property dtsJobName: The name of the DTS instance.

source_endpointRequired 

source_endpoint: typing.Union[IResolvable, SourceEndpointProperty]

Property sourceEndpoint: Source instance configuration.

subscription_instanceRequired 

subscription_instance: typing.Union[IResolvable, SubscriptionInstanceProperty]

Property subscriptionInstance: Subscription instance configuration.

checkpointOptional 

checkpoint: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property checkpoint: 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.

dedicated_cluster_idOptional 

dedicated_cluster_id: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property dedicatedClusterId: The ID of the DTS dedicated cluster on which the task runs.

delay_noticeOptional 

delay_notice: typing.Union[bool, IResolvable]
  • Type: typing.Union[bool, ros_cdk_core.IResolvable]

Property delayNotice: Specifies whether to monitor the task latency.

Valid values: true and false

delay_phoneOptional 

delay_phone: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property delayPhone: 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.

delay_rule_timeOptional 

delay_rule_time: typing.Union[typing.Union[int, float], IResolvable]
  • Type: typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable]

Property delayRuleTime: 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.

dts_bis_labelOptional 

dts_bis_label: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property dtsBisLabel: The environment tag of the DTS instance.

Valid values: normal and online.

dts_instance_idOptional 

dts_instance_id: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property dtsInstanceId: The ID of the DTS instance.

dts_job_idOptional 

dts_job_id: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property dtsJobId: The ID of the DTS task.

error_noticeOptional 

error_notice: typing.Union[bool, IResolvable]
  • Type: typing.Union[bool, ros_cdk_core.IResolvable]

Property errorNotice: Specifies whether to monitor the task status.

Valid values: true and false.

error_phoneOptional 

error_phone: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property errorPhone: 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.

reserveOptional 

reserve: typing.Union[IResolvable, typing.Mapping[typing.Any]]
  • Type: typing.Union[ros_cdk_core.IResolvable, typing.Mapping[typing.Any]]

Property reserve: 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.

statusOptional 

status: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property status: The status of the resource.

Valid values:

  • Subscribing: Start the task.
  • Suspending: Suspend the task.
  • Stopping: Stop the task.

subscription_data_typeOptional 

subscription_data_type: typing.Union[IResolvable, SubscriptionDataTypeProperty]

Property subscriptionDataType: Subscription data type.