lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.476 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.477
- old
+ new
@@ -311,10 +311,27 @@
@Result = params['Result']
@RequestId = params['RequestId']
end
end
+ # 批量解析
+ class BatchAnalyseParam < TencentCloud::Common::AbstractModel
+ # @param Format: ONE_BY_ONE单条输出，MERGE合并输出
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type Format: String
+
+ attr_accessor :Format
+
+ def initialize(format=nil)
+ @Format = format
+ end
+
+ def deserialize(params)
+ @Format = params['Format']
+ end
+ end
+
# 批量发送消息内容
class BatchContent < TencentCloud::Common::AbstractModel
# @param Body: 发送的消息体
# @type Body: String
# @param Key: 发送消息的键名
@@ -2477,14 +2494,17 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SQLServerParam: :class:`Tencentcloud::Ckafka.v20190819.models.SQLServerParam`
# @param CtsdbParam: Ctsdb配置，Type为CTSDB时必填
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CtsdbParam: :class:`Tencentcloud::Ckafka.v20190819.models.CtsdbParam`
+ # @param ScfParam: Scf配置，Type为SCF时必填
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type ScfParam: :class:`Tencentcloud::Ckafka.v20190819.models.ScfParam`
- attr_accessor :Type, :KafkaParam, :EventBusParam, :MongoDBParam, :EsParam, :TdwParam, :DtsParam, :ClickHouseParam, :ClsParam, :CosParam, :MySQLParam, :PostgreSQLParam, :TopicParam, :MariaDBParam, :SQLServerParam, :CtsdbParam
+ attr_accessor :Type, :KafkaParam, :EventBusParam, :MongoDBParam, :EsParam, :TdwParam, :DtsParam, :ClickHouseParam, :ClsParam, :CosParam, :MySQLParam, :PostgreSQLParam, :TopicParam, :MariaDBParam, :SQLServerParam, :CtsdbParam, :ScfParam
- def initialize(type=nil, kafkaparam=nil, eventbusparam=nil, mongodbparam=nil, esparam=nil, tdwparam=nil, dtsparam=nil, clickhouseparam=nil, clsparam=nil, cosparam=nil, mysqlparam=nil, postgresqlparam=nil, topicparam=nil, mariadbparam=nil, sqlserverparam=nil, ctsdbparam=nil)
+ def initialize(type=nil, kafkaparam=nil, eventbusparam=nil, mongodbparam=nil, esparam=nil, tdwparam=nil, dtsparam=nil, clickhouseparam=nil, clsparam=nil, cosparam=nil, mysqlparam=nil, postgresqlparam=nil, topicparam=nil, mariadbparam=nil, sqlserverparam=nil, ctsdbparam=nil, scfparam=nil)
@Type = type
@KafkaParam = kafkaparam
@EventBusParam = eventbusparam
@MongoDBParam = mongodbparam
@EsParam = esparam
@@ -2497,10 +2517,11 @@
@PostgreSQLParam = postgresqlparam
@TopicParam = topicparam
@MariaDBParam = mariadbparam
@SQLServerParam = sqlserverparam
@CtsdbParam = ctsdbparam
+ @ScfParam = scfparam
end
def deserialize(params)
@Type = params['Type']
unless params['KafkaParam'].nil?
@@ -2561,10 +2582,14 @@
end
unless params['CtsdbParam'].nil?
@CtsdbParam = CtsdbParam.new
@CtsdbParam.deserialize(params['CtsdbParam'])
end
+ unless params['ScfParam'].nil?
+ @ScfParam = ScfParam.new
+ @ScfParam.deserialize(params['ScfParam'])
+ end
end
end
# Datahub请求的taskid
class DatahubTaskIdRes < TencentCloud::Common::AbstractModel
@@ -5338,14 +5363,16 @@
# @type IndexType: String
# @param DropCls: 当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效
# @type DropCls: :class:`Tencentcloud::Ckafka.v20190819.models.DropCls`
# @param DatabasePrimaryKey: 转储到ES的消息为Database的binlog时，如果需要同步数据库操作，即增删改的操作到ES时填写数据库表主键
# @type DatabasePrimaryKey: String
+ # @param DropDlq: 死信队列
+ # @type DropDlq: :class:`Tencentcloud::Ckafka.v20190819.models.FailureParam`
- attr_accessor :Resource, :Port, :UserName, :Password, :SelfBuilt, :ServiceVip, :UniqVpcId, :DropInvalidMessage, :Index, :DateFormat, :ContentKey, :DropInvalidJsonMessage, :DocumentIdField, :IndexType, :DropCls, :DatabasePrimaryKey
+ attr_accessor :Resource, :Port, :UserName, :Password, :SelfBuilt, :ServiceVip, :UniqVpcId, :DropInvalidMessage, :Index, :DateFormat, :ContentKey, :DropInvalidJsonMessage, :DocumentIdField, :IndexType, :DropCls, :DatabasePrimaryKey, :DropDlq
- def initialize(resource=nil, port=nil, username=nil, password=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, dropinvalidmessage=nil, index=nil, dateformat=nil, contentkey=nil, dropinvalidjsonmessage=nil, documentidfield=nil, indextype=nil, dropcls=nil, databaseprimarykey=nil)
+ def initialize(resource=nil, port=nil, username=nil, password=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, dropinvalidmessage=nil, index=nil, dateformat=nil, contentkey=nil, dropinvalidjsonmessage=nil, documentidfield=nil, indextype=nil, dropcls=nil, databaseprimarykey=nil, dropdlq=nil)
@Resource = resource
@Port = port
@UserName = username
@Password = password
@SelfBuilt = selfbuilt
@@ -5358,10 +5385,11 @@
@DropInvalidJsonMessage = dropinvalidjsonmessage
@DocumentIdField = documentidfield
@IndexType = indextype
@DropCls = dropcls
@DatabasePrimaryKey = databaseprimarykey
+ @DropDlq = dropdlq
end
def deserialize(params)
@Resource = params['Resource']
@Port = params['Port']
@@ -5380,10 +5408,14 @@
unless params['DropCls'].nil?
@DropCls = DropCls.new
@DropCls.deserialize(params['DropCls'])
end
@DatabasePrimaryKey = params['DatabasePrimaryKey']
+ unless params['DropDlq'].nil?
+ @DropDlq = FailureParam.new
+ @DropDlq.deserialize(params['DropDlq'])
+ end
end
end
# EventBus配置
class EventBusParam < TencentCloud::Common::AbstractModel
@@ -7026,14 +7058,17 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UseAutoCreateTopic: Boolean
# @param CompressionType: 写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CompressionType: String
+ # @param MsgMultiple: 源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type MsgMultiple: Integer
- attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType
+ attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType, :MsgMultiple
- 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)
+ 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, msgmultiple=nil)
@SelfBuilt = selfbuilt
@Resource = resource
@Topic = topic
@OffsetType = offsettype
@StartTime = starttime
@@ -7045,10 +7080,11 @@
@QpsLimit = qpslimit
@TableMappings = tablemappings
@UseTableMapping = usetablemapping
@UseAutoCreateTopic = useautocreatetopic
@CompressionType = compressiontype
+ @MsgMultiple = msgmultiple
end
def deserialize(params)
@SelfBuilt = params['SelfBuilt']
@Resource = params['Resource']
@@ -7070,10 +7106,11 @@
end
end
@UseTableMapping = params['UseTableMapping']
@UseAutoCreateTopic = params['UseAutoCreateTopic']
@CompressionType = params['CompressionType']
+ @MsgMultiple = params['MsgMultiple']
end
end
# Map参数
class MapParam < TencentCloud::Common::AbstractModel
@@ -8944,10 +8981,45 @@
@Platform = params['Platform']
@SoldOut = params['SoldOut']
end
end
+ # Scf类型入参
+ class ScfParam < TencentCloud::Common::AbstractModel
+ # @param FunctionName: SCF云函数函数名
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type FunctionName: String
+ # @param Namespace: SCF云函数命名空间, 默认为default
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type Namespace: String
+ # @param Qualifier: SCF云函数版本及别名, 默认为$DEFAULT
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type Qualifier: String
+ # @param BatchSize: 每批最大发送消息数, 默认为1000
+ # @type BatchSize: Integer
+ # @param MaxRetries: SCF调用失败后重试次数, 默认为5
+ # @type MaxRetries: Integer
+
+ attr_accessor :FunctionName, :Namespace, :Qualifier, :BatchSize, :MaxRetries
+
+ def initialize(functionname=nil, namespace=nil, qualifier=nil, batchsize=nil, maxretries=nil)
+ @FunctionName = functionname
+ @Namespace = namespace
+ @Qualifier = qualifier
+ @BatchSize = batchsize
+ @MaxRetries = maxretries
+ end
+
+ def deserialize(params)
+ @FunctionName = params['FunctionName']
+ @Namespace = params['Namespace']
+ @Qualifier = params['Qualifier']
+ @BatchSize = params['BatchSize']
+ @MaxRetries = params['MaxRetries']
+ end
+ end
+
# 数据处理——二次解析参数
class SecondaryAnalyseParam < TencentCloud::Common::AbstractModel
# @param Regex: 分隔符
# @type Regex: String
@@ -9467,29 +9539,34 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CompressionType: String
# @param UseAutoCreateTopic: 使用的Topic是否需要自动创建（目前只支持SOURCE流入任务）
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UseAutoCreateTopic: Boolean
+ # @param MsgMultiple: 源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type MsgMultiple: Integer
- attr_accessor :Resource, :OffsetType, :StartTime, :TopicId, :CompressionType, :UseAutoCreateTopic
+ attr_accessor :Resource, :OffsetType, :StartTime, :TopicId, :CompressionType, :UseAutoCreateTopic, :MsgMultiple
- def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil, compressiontype=nil, useautocreatetopic=nil)
+ def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil, compressiontype=nil, useautocreatetopic=nil, msgmultiple=nil)
@Resource = resource
@OffsetType = offsettype
@StartTime = starttime
@TopicId = topicid
@CompressionType = compressiontype
@UseAutoCreateTopic = useautocreatetopic
+ @MsgMultiple = msgmultiple
end
def deserialize(params)
@Resource = params['Resource']
@OffsetType = params['OffsetType']
@StartTime = params['StartTime']
@TopicId = params['TopicId']
@CompressionType = params['CompressionType']
@UseAutoCreateTopic = params['UseAutoCreateTopic']
+ @MsgMultiple = params['MsgMultiple']
end
end
# 分区详情
class TopicPartitionDO < TencentCloud::Common::AbstractModel
@@ -9720,23 +9797,27 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RowParam: :class:`Tencentcloud::Ckafka.v20190819.models.RowParam`
# @param KeepMetadata: 是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false
# 注意：此字段可能返回 null，表示取不到有效值。
# @type KeepMetadata: Boolean
+ # @param BatchAnalyse: 数组解析
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type BatchAnalyse: :class:`Tencentcloud::Ckafka.v20190819.models.BatchAnalyseParam`
- attr_accessor :Content, :FieldChain, :FilterParam, :FailureParam, :Result, :SourceType, :OutputFormat, :RowParam, :KeepMetadata
+ attr_accessor :Content, :FieldChain, :FilterParam, :FailureParam, :Result, :SourceType, :OutputFormat, :RowParam, :KeepMetadata, :BatchAnalyse
- def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil, keepmetadata=nil)
+ def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil, keepmetadata=nil, batchanalyse=nil)
@Content = content
@FieldChain = fieldchain
@FilterParam = filterparam
@FailureParam = failureparam
@Result = result
@SourceType = sourcetype
@OutputFormat = outputformat
@RowParam = rowparam
@KeepMetadata = keepmetadata
+ @BatchAnalyse = batchanalyse
end
def deserialize(params)
@Content = params['Content']
unless params['FieldChain'].nil?
@@ -9765,9 +9846,13 @@
unless params['RowParam'].nil?
@RowParam = RowParam.new
@RowParam.deserialize(params['RowParam'])
end
@KeepMetadata = params['KeepMetadata']
+ unless params['BatchAnalyse'].nil?
+ @BatchAnalyse = BatchAnalyseParam.new
+ @BatchAnalyse.deserialize(params['BatchAnalyse'])
+ end
end
end
# Url解析
class UrlDecodeParam < TencentCloud::Common::AbstractModel