lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.434 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.435
- old
+ new
@@ -6579,14 +6579,20 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TableMappings: Array
# @param UseTableMapping: 「分发到多个topic」开关，默认为false
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UseTableMapping: Boolean
+ # @param UseAutoCreateTopic: 使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type UseAutoCreateTopic: Boolean
+ # @param CompressionType: 写入Topic时是否进行压缩，不开启填"none"，开启的话，可选择"gzip", "snappy", "lz4"中的一个进行填写。
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type CompressionType: String
- attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping
+ attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType
- def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil)
+ def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil, useautocreatetopic=nil, compressiontype=nil)
@SelfBuilt = selfbuilt
@Resource = resource
@Topic = topic
@OffsetType = offsettype
@StartTime = starttime
@@ -6596,10 +6602,12 @@
@PartitionNum = partitionnum
@EnableToleration = enabletoleration
@QpsLimit = qpslimit
@TableMappings = tablemappings
@UseTableMapping = usetablemapping
+ @UseAutoCreateTopic = useautocreatetopic
+ @CompressionType = compressiontype
end
def deserialize(params)
@SelfBuilt = params['SelfBuilt']
@Resource = params['Resource']
@@ -6619,10 +6627,12 @@
tablemapping_tmp.deserialize(i)
@TableMappings << tablemapping_tmp
end
end
@UseTableMapping = params['UseTableMapping']
+ @UseAutoCreateTopic = params['UseAutoCreateTopic']
+ @CompressionType = params['CompressionType']
end
end
# Map参数
class MapParam < TencentCloud::Common::AbstractModel
@@ -7626,11 +7636,11 @@
# MySQL类型入参
class MySQLParam < TencentCloud::Common::AbstractModel
# @param Database: MySQL的数据库名称，"*"为全数据库
# @type Database: String
- # @param Table: MySQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"数据库名.数据表名"的格式进行填写
+ # @param Table: MySQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"数据库名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"数据库名\\.数据表名"
# @type Table: String
# @param Resource: 该MySQL在连接管理内的Id
# @type Resource: String
# @param SnapshotMode: 复制存量信息(schema_only不复制, initial全量)，默认位initial
# @type SnapshotMode: String
@@ -7672,14 +7682,16 @@
# @type IncludeQuery: Boolean
# @param RecordWithSchema: 如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带
# @type RecordWithSchema: Boolean
# @param SignalDatabase: 存放信令表的数据库名称
# @type SignalDatabase: String
+ # @param IsTableRegular: 输入的table是否为正则表达式，如果该选项以及IsTablePrefix同时为true，该选项的判断优先级高于IsTablePrefix
+ # @type IsTableRegular: 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
+ 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
- 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)
+ 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)
@Database = database
@Table = table
@Resource = resource
@SnapshotMode = snapshotmode
@DdlTopic = ddltopic
@@ -7700,10 +7712,11 @@
@IsTablePrefix = istableprefix
@IncludeContentChanges = includecontentchanges
@IncludeQuery = includequery
@RecordWithSchema = recordwithschema
@SignalDatabase = signaldatabase
+ @IsTableRegular = istableregular
end
def deserialize(params)
@Database = params['Database']
@Table = params['Table']
@@ -7737,10 +7750,11 @@
@IsTablePrefix = params['IsTablePrefix']
@IncludeContentChanges = params['IncludeContentChanges']
@IncludeQuery = params['IncludeQuery']
@RecordWithSchema = params['RecordWithSchema']
@SignalDatabase = params['SignalDatabase']
+ @IsTableRegular = params['IsTableRegular']
end
end
# 操作类型返回的Data结构
class OperateResponseData < TencentCloud::Common::AbstractModel
@@ -7933,11 +7947,11 @@
# PostgreSQL类型入参
class PostgreSQLParam < TencentCloud::Common::AbstractModel
# @param Database: PostgreSQL的数据库名称
# @type Database: String
- # @param Table: PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"数据库名.数据表名"的格式进行填写
+ # @param Table: PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\\.数据表名"
# @type Table: String
# @param Resource: 该PostgreSQL在连接管理内的Id
# @type Resource: String
# @param PluginName: 插件名(decoderbufs/pgoutput)，默认为decoderbufs
# @type PluginName: String
@@ -9006,24 +9020,34 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StartTime: Integer
# @param TopicId: Topic的TopicId【出参】
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TopicId: String
+ # @param CompressionType: 写入Topic时是否进行压缩，不开启填"none"，开启的话，可选择"gzip", "snappy", "lz4"中的一个进行填写。
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type CompressionType: String
+ # @param UseAutoCreateTopic: 使用的Topic是否需要自动创建（目前只支持SOURCE流入任务）
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type UseAutoCreateTopic: Boolean
- attr_accessor :Resource, :OffsetType, :StartTime, :TopicId
+ attr_accessor :Resource, :OffsetType, :StartTime, :TopicId, :CompressionType, :UseAutoCreateTopic
- def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil)
+ def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil, compressiontype=nil, useautocreatetopic=nil)
@Resource = resource
@OffsetType = offsettype
@StartTime = starttime
@TopicId = topicid
+ @CompressionType = compressiontype
+ @UseAutoCreateTopic = useautocreatetopic
end
def deserialize(params)
@Resource = params['Resource']
@OffsetType = params['OffsetType']
@StartTime = params['StartTime']
@TopicId = params['TopicId']
+ @CompressionType = params['CompressionType']
+ @UseAutoCreateTopic = params['UseAutoCreateTopic']
end
end
# 分区详情
class TopicPartitionDO < TencentCloud::Common::AbstractModel