models.rb in tencentcloud-sdk-ckafka-3.0.416

- old
+ new

@@ -1602,23 +1602,26 @@
         # @type SchemaId: String
         # @param TransformsParam: 数据处理规则
         # @type TransformsParam: :class:`Tencentcloud::Ckafka.v20190819.models.TransformsParam`
         # @param TaskId: 任务ID
         # @type TaskId: String
+        # @param Tags: 标签列表
+        # @type Tags: Array
 
-        attr_accessor :TaskName, :TaskType, :SourceResource, :TargetResource, :TransformParam, :PrivateLinkParam, :SchemaId, :TransformsParam, :TaskId
+        attr_accessor :TaskName, :TaskType, :SourceResource, :TargetResource, :TransformParam, :PrivateLinkParam, :SchemaId, :TransformsParam, :TaskId, :Tags
         
-        def initialize(taskname=nil, tasktype=nil, sourceresource=nil, targetresource=nil, transformparam=nil, privatelinkparam=nil, schemaid=nil, transformsparam=nil, taskid=nil)
+        def initialize(taskname=nil, tasktype=nil, sourceresource=nil, targetresource=nil, transformparam=nil, privatelinkparam=nil, schemaid=nil, transformsparam=nil, taskid=nil, tags=nil)
           @TaskName = taskname
           @TaskType = tasktype
           @SourceResource = sourceresource
           @TargetResource = targetresource
           @TransformParam = transformparam
           @PrivateLinkParam = privatelinkparam
           @SchemaId = schemaid
           @TransformsParam = transformsparam
           @TaskId = taskid
+          @Tags = tags
         end
 
         def deserialize(params)
           @TaskName = params['TaskName']
           @TaskType = params['TaskType']
@@ -1642,10 +1645,18 @@
           unless params['TransformsParam'].nil?
             @TransformsParam = TransformsParam.new
             @TransformsParam.deserialize(params['TransformsParam'])
           end
           @TaskId = params['TaskId']
+          unless params['Tags'].nil?
+            @Tags = []
+            params['Tags'].each do |i|
+              tag_tmp = Tag.new
+              tag_tmp.deserialize(i)
+              @Tags << tag_tmp
+            end
+          end
         end
       end
 
       # 创建数据转储返回值
       class CreateDatahubTaskRes < TencentCloud::Common::AbstractModel
@@ -3803,14 +3814,17 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type TransformsParam: :class:`Tencentcloud::Ckafka.v20190819.models.TransformsParam`
         # @param ErrorMessage: 异常信息
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type ErrorMessage: String
+        # @param Tags: 任务标签列表
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type Tags: Array
 
-        attr_accessor :TaskId, :TaskName, :TaskType, :Status, :SourceResource, :TargetResource, :Connections, :CreateTime, :TransformParam, :DatahubId, :SchemaId, :SchemaName, :TransformsParam, :ErrorMessage
+        attr_accessor :TaskId, :TaskName, :TaskType, :Status, :SourceResource, :TargetResource, :Connections, :CreateTime, :TransformParam, :DatahubId, :SchemaId, :SchemaName, :TransformsParam, :ErrorMessage, :Tags
         
-        def initialize(taskid=nil, taskname=nil, tasktype=nil, status=nil, sourceresource=nil, targetresource=nil, connections=nil, createtime=nil, transformparam=nil, datahubid=nil, schemaid=nil, schemaname=nil, transformsparam=nil, errormessage=nil)
+        def initialize(taskid=nil, taskname=nil, tasktype=nil, status=nil, sourceresource=nil, targetresource=nil, connections=nil, createtime=nil, transformparam=nil, datahubid=nil, schemaid=nil, schemaname=nil, transformsparam=nil, errormessage=nil, tags=nil)
           @TaskId = taskid
           @TaskName = taskname
           @TaskType = tasktype
           @Status = status
           @SourceResource = sourceresource
@@ -3821,10 +3835,11 @@
           @DatahubId = datahubid
           @SchemaId = schemaid
           @SchemaName = schemaname
           @TransformsParam = transformsparam
           @ErrorMessage = errormessage
+          @Tags = tags
         end
 
         def deserialize(params)
           @TaskId = params['TaskId']
           @TaskName = params['TaskName']
@@ -3857,10 +3872,18 @@
           unless params['TransformsParam'].nil?
             @TransformsParam = TransformsParam.new
             @TransformsParam.deserialize(params['TransformsParam'])
           end
           @ErrorMessage = params['ErrorMessage']
+          unless params['Tags'].nil?
+            @Tags = []
+            params['Tags'].each do |i|
+              tag_tmp = Tag.new
+              tag_tmp.deserialize(i)
+              @Tags << tag_tmp
+            end
+          end
         end
       end
 
       # DescribeDatahubTask返回参数结构体
       class DescribeDatahubTaskResponse < TencentCloud::Common::AbstractModel
@@ -6336,10 +6359,30 @@
             @Data.deserialize(params['Data'])
           end
         end
       end
 
+      # 数据处理——Value处理参数——Jsonpath替换参数
+      class JsonPathReplaceParam < TencentCloud::Common::AbstractModel
+        # @param OldValue: 被替换值，Jsonpath表达式
+        # @type OldValue: String
+        # @param NewValue: 替换值，Jsonpath表达式或字符串
+        # @type NewValue: String
+
+        attr_accessor :OldValue, :NewValue
+        
+        def initialize(oldvalue=nil, newvalue=nil)
+          @OldValue = oldvalue
+          @NewValue = newvalue
+        end
+
+        def deserialize(params)
+          @OldValue = params['OldValue']
+          @NewValue = params['NewValue']
+        end
+      end
+
       # key-value二次解析
       class KVParam < TencentCloud::Common::AbstractModel
         # @param Delimiter: 分隔符
         # @type Delimiter: String
         # @param Regex: key-value二次解析分隔符
@@ -9193,22 +9236,26 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type KV: :class:`Tencentcloud::Ckafka.v20190819.models.KVParam`
         # @param Result: 处理结果
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Result: String
+        # @param JsonPathReplace: JsonPath替换，TYPE=JSON_PATH_REPLACE时必传
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type JsonPathReplace: :class:`Tencentcloud::Ckafka.v20190819.models.JsonPathReplaceParam`
 
-        attr_accessor :Type, :Replace, :Substr, :Date, :RegexReplace, :Split, :KV, :Result
+        attr_accessor :Type, :Replace, :Substr, :Date, :RegexReplace, :Split, :KV, :Result, :JsonPathReplace
         
-        def initialize(type=nil, replace=nil, substr=nil, date=nil, regexreplace=nil, split=nil, kv=nil, result=nil)
+        def initialize(type=nil, replace=nil, substr=nil, date=nil, regexreplace=nil, split=nil, kv=nil, result=nil, jsonpathreplace=nil)
           @Type = type
           @Replace = replace
           @Substr = substr
           @Date = date
           @RegexReplace = regexreplace
           @Split = split
           @KV = kv
           @Result = result
+          @JsonPathReplace = jsonpathreplace
         end
 
         def deserialize(params)
           @Type = params['Type']
           unless params['Replace'].nil?
@@ -9234,9 +9281,13 @@
           unless params['KV'].nil?
             @KV = KVParam.new
             @KV.deserialize(params['KV'])
           end
           @Result = params['Result']
+          unless params['JsonPathReplace'].nil?
+            @JsonPathReplace = JsonPathReplaceParam.new
+            @JsonPathReplace.deserialize(params['JsonPathReplace'])
+          end
         end
       end
 
       # 虚拟IP实体
       class VipEntity < TencentCloud::Common::AbstractModel