Class: TencentCloud::Dts::V20211206::Options

Inherits:

Common::AbstractModel

• Object
• Common::AbstractModel
• TencentCloud::Dts::V20211206::Options

Defined in:

lib/v20211206/models.rb

Overview

数据同步中的选项

Instance Attribute Summary

• #AddAdditionalColumn ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #AutoRetryTimeRangeMinutes ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #ConflictHandleOption ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #ConflictHandleType ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #DdlOptions ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #DealOfExistSameTable ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #FilterBeginCommit ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #FilterCheckpoint ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #InitType ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #KafkaOption ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #OpTypes ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #RateLimitOption ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

• #StartPosition ⇒ Object

  注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。.

Instance Method Summary

• #deserialize(params) ⇒ Object
• #initialize(inittype = nil, dealofexistsametable = nil, conflicthandletype = nil, addadditionalcolumn = nil, optypes = nil, conflicthandleoption = nil, ddloptions = nil, kafkaoption = nil, ratelimitoption = nil, autoretrytimerangeminutes = nil, startposition = nil, filterbegincommit = nil, filtercheckpoint = nil) ⇒ Options constructor

  A new instance of Options.

Constructor Details

#initialize(inittype = nil, dealofexistsametable = nil, conflicthandletype = nil, addadditionalcolumn = nil, optypes = nil, conflicthandleoption = nil, ddloptions = nil, kafkaoption = nil, ratelimitoption = nil, autoretrytimerangeminutes = nil, startposition = nil, filterbegincommit = nil, filtercheckpoint = nil) ⇒ Options

Returns a new instance of Options.

# File 'lib/v20211206/models.rb', line 5828

def initialize(inittype=nil, dealofexistsametable=nil, conflicthandletype=nil, addadditionalcolumn=nil, optypes=nil, conflicthandleoption=nil, ddloptions=nil, kafkaoption=nil, ratelimitoption=nil, autoretrytimerangeminutes=nil, startposition=nil, filterbegincommit=nil, filtercheckpoint=nil)
  @InitType = inittype
  @DealOfExistSameTable = dealofexistsametable
  @ConflictHandleType = conflicthandletype
  @AddAdditionalColumn = addadditionalcolumn
  @OpTypes = optypes
  @ConflictHandleOption = conflicthandleoption
  @DdlOptions = ddloptions
  @KafkaOption = kafkaoption
  @RateLimitOption = ratelimitoption
  @AutoRetryTimeRangeMinutes = autoretrytimerangeminutes
  @StartPosition = startposition
  @FilterBeginCommit = filterbegincommit
  @FilterCheckpoint = filtercheckpoint
end

Instance Attribute Details

#AddAdditionalColumn ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def AddAdditionalColumn
  @AddAdditionalColumn
end

#AutoRetryTimeRangeMinutes ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def AutoRetryTimeRangeMinutes
  @AutoRetryTimeRangeMinutes
end

#ConflictHandleOption ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def ConflictHandleOption
  @ConflictHandleOption
end

#ConflictHandleType ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def ConflictHandleType
  @ConflictHandleType
end

#DdlOptions ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def DdlOptions
  @DdlOptions
end

#DealOfExistSameTable ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def DealOfExistSameTable
  @DealOfExistSameTable
end

#FilterBeginCommit ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def FilterBeginCommit
  @FilterBeginCommit
end

#FilterCheckpoint ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def FilterCheckpoint
  @FilterCheckpoint
end

#InitType ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def InitType
  @InitType
end

#KafkaOption ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def KafkaOption
  @KafkaOption
end

#OpTypes ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def OpTypes
  @OpTypes
end

#RateLimitOption ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def RateLimitOption
  @RateLimitOption
end

#StartPosition ⇒ Object

注意：此字段可能返回 null，表示取不到有效值。 注意：此字段可能返回 null，表示取不到有效值。

Parameters:

• InitType: —

  同步初始化选项，Data(全量数据初始化)、Structure(结构初始化)、Full(全量数据且结构初始化，默认)、None(仅增量)；mongodb链路只支持全量数据初始化或仅增量。

• DealOfExistSameTable: —

  同名表的处理，ReportErrorAfterCheck(前置校验并报错，默认)、ExecuteAfterIgnore(忽略并继续执行)

• ConflictHandleType: —

  冲突处理选项，ReportError(报错，默认为该值)、Ignore(忽略)、Cover(覆盖)、ConditionCover(条件覆盖)

• AddAdditionalColumn: —

  是否添加附加列

• OpTypes: —

  所要同步的DML和DDL的选项，Insert(插入操作)、Update(更新操作)、Delete(删除操作)、DDL(结构同步)， PartialDDL(自定义,和DdlOptions一起配合使用)。注意，这里至少需要包含DML中的一种。

• ConflictHandleOption: —

  冲突处理的详细选项，如条件覆盖中的条件行和条件操作

• DdlOptions: —

  DDL同步选项，具体描述要同步哪些DDL

• KafkaOption: —

  kafka同步选项

• RateLimitOption: —

  任务限速信息

• AutoRetryTimeRangeMinutes: —

  自动重试的时间窗口设置

• StartPosition: —

  同步到kafka链路指定位点。目前只支持时间格式：2023-12-20T19:24:23+08:00。如果没有指定位点，为空。

• FilterBeginCommit: —

  同步到kafka链路是否过滤掉begin和commit消息。目前仅mysql2kafka链路支持

• FilterCheckpoint: —

  同步到kafka链路是否过滤掉checkpoint消息。目前仅mysql2kafka链路支持

# File 'lib/v20211206/models.rb', line 5826

def StartPosition
  @StartPosition
end

Instance Method Details

#deserialize(params) ⇒ Object

# File 'lib/v20211206/models.rb', line 5844

def deserialize(params)
  @InitType = params['InitType']
  @DealOfExistSameTable = params['DealOfExistSameTable']
  @ConflictHandleType = params['ConflictHandleType']
  @AddAdditionalColumn = params['AddAdditionalColumn']
  @OpTypes = params['OpTypes']
  unless params['ConflictHandleOption'].nil?
    @ConflictHandleOption = ConflictHandleOption.new
    @ConflictHandleOption.deserialize(params['ConflictHandleOption'])
  end
  unless params['DdlOptions'].nil?
    @DdlOptions = []
    params['DdlOptions'].each do |i|
      ddloption_tmp = DdlOption.new
      ddloption_tmp.deserialize(i)
      @DdlOptions << ddloption_tmp
    end
  end
  unless params['KafkaOption'].nil?
    @KafkaOption = KafkaOption.new
    @KafkaOption.deserialize(params['KafkaOption'])
  end
  unless params['RateLimitOption'].nil?
    @RateLimitOption = RateLimitOption.new
    @RateLimitOption.deserialize(params['RateLimitOption'])
  end
  @AutoRetryTimeRangeMinutes = params['AutoRetryTimeRangeMinutes']
  @StartPosition = params['StartPosition']
  @FilterBeginCommit = params['FilterBeginCommit']
  @FilterCheckpoint = params['FilterCheckpoint']
end