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