lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.685 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.686
- old
+ new
@@ -9472,65 +9472,97 @@
end
# MySQL类型入参
class MySQLParam < TencentCloud::Common::AbstractModel
# @param Database: MySQL的数据库名称,"*"为全数据库
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type Database: String
# @param Table: MySQL的数据表名称,"*"为所监听的所有数据库中的非系统表,可以","间隔,监听多个数据表,但数据表需要以"数据库名.数据表名"的格式进行填写,需要填入正则表达式时,格式为"数据库名\\.数据表名"
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type Table: String
# @param Resource: 该MySQL在连接管理内的Id
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type Resource: String
# @param SnapshotMode: 复制存量信息(schema_only不复制, initial全量),默认位initial
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type SnapshotMode: String
# @param DdlTopic: 存放MySQL的Ddl信息的Topic,为空则默认不存放
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DdlTopic: String
# @param DataSourceMonitorMode: "TABLE" 表示读取项为 table,"QUERY" 表示读取项为 query
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataSourceMonitorMode: String
# @param DataSourceMonitorResource: 当 "DataMonitorMode"="TABLE" 时,传入需要读取的 Table;当 "DataMonitorMode"="QUERY" 时,传入需要读取的查询 sql 语句
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataSourceMonitorResource: String
# @param DataSourceIncrementMode: "TIMESTAMP" 表示增量列为时间戳类型,"INCREMENT" 表示增量列为自增 id 类型
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataSourceIncrementMode: String
# @param DataSourceIncrementColumn: 传入需要监听的列名称
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataSourceIncrementColumn: String
# @param DataSourceStartFrom: "HEAD" 表示复制存量 + 增量数据,"TAIL" 表示只复制增量数据
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataSourceStartFrom: String
# @param DataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入,"UPSERT" 表示使用 Upsert 模式插入
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataTargetInsertMode: String
# @param DataTargetPrimaryKeyField: 当 "DataInsertMode"="UPSERT" 时,传入当前 upsert 时依赖的主键
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataTargetPrimaryKeyField: String
# @param DataTargetRecordMapping: 表与消息间的映射关系
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DataTargetRecordMapping: Array
# @param TopicRegex: 事件路由到特定主题的正则表达式,默认为(.*)
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type TopicRegex: String
# @param TopicReplacement: TopicRegex的引用组,指定$1、$2等
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type TopicReplacement: String
# @param KeyColumns: 格式:库1.表1:字段1,字段2;库2.表2:字段2,表之间;(分号)隔开,字段之间,(逗号)隔开。不指定的表默认取表的主键
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type KeyColumns: String
# @param DropInvalidMessage: Mysql 是否抛弃解析失败的消息,默认为true
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DropInvalidMessage: Boolean
# @param DropCls: 当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type DropCls: :class:`Tencentcloud::Ckafka.v20190819.models.DropCls`
# @param OutputFormat: 输出格式,DEFAULT、CANAL_1、CANAL_2
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type OutputFormat: String
# @param IsTablePrefix: 当Table输入的是前缀时,该项值为true,否则为false
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type IsTablePrefix: Boolean
# @param IncludeContentChanges: 如果该值为all,则DDL数据以及DML数据也会写入到选中的topic;若该值为dml,则只有DML数据写入到选中的topic
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type IncludeContentChanges: String
# @param IncludeQuery: 如果该值为true,且MySQL中"binlog_rows_query_log_events"配置项的值为"ON",则流入到topic的数据包含原SQL语句;若该值为false,流入到topic的数据不包含原SQL语句
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type IncludeQuery: Boolean
# @param RecordWithSchema: 如果该值为 true,则消息中会携带消息结构体对应的schema,如果该值为false则不会携带
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type RecordWithSchema: Boolean
# @param SignalDatabase: 存放信令表的数据库名称
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type SignalDatabase: String
# @param IsTableRegular: 输入的table是否为正则表达式,如果该选项以及IsTablePrefix同时为true,该选项的判断优先级高于IsTablePrefix
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type IsTableRegular: Boolean
# @param SignalTable: 信号表
+ # 注意:此字段可能返回 null,表示取不到有效值。
# @type SignalTable: String
+ # @param DateTimeZone: datetime 类型字段转换为时间戳的时区
+ # 注意:此字段可能返回 null,表示取不到有效值。
+ # @type DateTimeZone: String
+ # @param SelfBuilt: 自建
+ # 注意:此字段可能返回 null,表示取不到有效值。
+ # @type SelfBuilt: Boolean
- attr_accessor :Database, :Table, :Resource, :SnapshotMode, :DdlTopic, :DataSourceMonitorMode, :DataSourceMonitorResource, :DataSourceIncrementMode, :DataSourceIncrementColumn, :DataSourceStartFrom, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping, :TopicRegex, :TopicReplacement, :KeyColumns, :DropInvalidMessage, :DropCls, :OutputFormat, :IsTablePrefix, :IncludeContentChanges, :IncludeQuery, :RecordWithSchema, :SignalDatabase, :IsTableRegular, :SignalTable
+ attr_accessor :Database, :Table, :Resource, :SnapshotMode, :DdlTopic, :DataSourceMonitorMode, :DataSourceMonitorResource, :DataSourceIncrementMode, :DataSourceIncrementColumn, :DataSourceStartFrom, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping, :TopicRegex, :TopicReplacement, :KeyColumns, :DropInvalidMessage, :DropCls, :OutputFormat, :IsTablePrefix, :IncludeContentChanges, :IncludeQuery, :RecordWithSchema, :SignalDatabase, :IsTableRegular, :SignalTable, :DateTimeZone, :SelfBuilt
- def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil)
+ def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil, datetimezone=nil, selfbuilt=nil)
@Database = database
@Table = table
@Resource = resource
@SnapshotMode = snapshotmode
@DdlTopic = ddltopic
@@ -9553,10 +9585,12 @@
@IncludeQuery = includequery
@RecordWithSchema = recordwithschema
@SignalDatabase = signaldatabase
@IsTableRegular = istableregular
@SignalTable = signaltable
+ @DateTimeZone = datetimezone
+ @SelfBuilt = selfbuilt
end
def deserialize(params)
@Database = params['Database']
@Table = params['Table']
@@ -9592,9 +9626,11 @@
@IncludeQuery = params['IncludeQuery']
@RecordWithSchema = params['RecordWithSchema']
@SignalDatabase = params['SignalDatabase']
@IsTableRegular = params['IsTableRegular']
@SignalTable = params['SignalTable']
+ @DateTimeZone = params['DateTimeZone']
+ @SelfBuilt = params['SelfBuilt']
end
end
# 操作类型返回的Data结构
class OperateResponseData < TencentCloud::Common::AbstractModel