微信的微网站模板,网站模板 html,不用网站怎么做落地页,马鞍山集团网站设计UpdateAttribute
描述:
通过设置属性表达式来更新属性#xff0c;也可以基于属性正则匹配来删除属性
标签:
attributes, modification, update, delete, Attribute Expression Language, state, 属性, 修改, 更新, 删除, 表达式
参数:
如下列表中#xff0c;必填参数则…UpdateAttribute
描述:
通过设置属性表达式来更新属性也可以基于属性正则匹配来删除属性
标签:
attributes, modification, update, delete, Attribute Expression Language, state, 属性, 修改, 更新, 删除, 表达式
参数:
如下列表中必填参数则标识为加粗. 其他未加粗参数则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
名字默认值允许值列表描述删除属性正则将删除与正则匹配相匹配的数据流上的属性 Existing attributes that match will be deleted regardless of whether they are updated by this processor. 支持表达式语言 (支持流属性和变量)存储状态不存储不存储仅本地存储是否需要存储状态选择“无状态”将提供以无状态方式单纯的更新流文件属性。选择有状态将不仅在数据流上存储属性还存储组件状态。 可查看组件高级设置的状态用法章节获取更多信息状态变量初始化值用于设置变量状态的初始值。 当状态中没有一个变量的值时该值仅被用在OnScheduled方法中。如果是有状态的则该参数是必须的但也可以设置为空
动态参数: 名字值描述A FlowFile attribute to updateThe value to set it to更新或设置一个数据流属性该参数可通过动态参数的键值来设置且与属性对应。 支持表达式语言 (支持流属性和变量) 连线:
名字描述success所有成功的数据流将输出到此连线
读取属性:
未提供。
写入属性:
名字描述See additional details组件可以添加或删除0到多个属性描述参见附加详细信息
状态管理:
范围描述LOCAL提供选项来存储数据流的属性值也引用有状态变量
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。 * 遇到的问题 问题1如何在Nifi中将属性设置为空字符串
解决方法${literal()}
试试
attribute_name
${literal()}
问题2增加一个属性 id2 233 输出结果 问题3条件判断
高级用法添加规则条件符合条件时update指定的属性值 点击ADVANCED 添加一个rule,如果id的值等于11就修改id的值为22 结果输出
问题4将属性提取到内容 需要增加ReplaceText组件 ${dict.51字段} 问题5删除某一些的属性 (orderParties|containerList|goods) UpdateAttribute清除body以外属性 (body.) Delete Attributes Expression
(SP.*\.[0-9].*) Delete Attributes Expression
bkCargo.*
它表示要删除以 bkCargo. 开头的所有属性。这种方式允许您一次性删除多个属性只要它们都以相同的前缀开始。
举个例子假设您有属性 bkCargo.name、bkCargo.type、bkCargo.weight 等等使用 bkCargo.* 表达式会删除所有以 bkCargo. 开头的属性将它们从数据中删除。 问题6日期获取 获取前一天的数据
dict.startTime${now():format(yyyy-MM-dd, GMT):toDate(yyyy-MM-dd):addDays(0):format(yyyy-MM-dd, GMT)}T00:00:00dict.endTime${now():format(yyyy-MM-dd, GMT):toDate(yyyy-MM-dd):addDays(0):format(yyyy-MM-dd, GMT)}T23:59:59 获取前2个月至今的数据
dict.startTime${now():format(yyyy-MM, GMT8):toDate(yyyy-MM):addMonths(-1):format(yyyy-MM, GMT)}-01T00:00:00dict.endTime${now():format(yyyy-MM-dd, GMT8)}T${now():format(HH:mm:ss, GMT8)} updateAttribute组件获取当前时间
${now():format(yyyy-MM-dd HH:mm:ss)}
问题7JsonPath表达式解读
dict.BLiStotalNoofPackages
${bkCargo:jsonPath($[?(.cargoFlag in [M])]):jsonPath($.noOfPackage)}
这段代码是使用 JSONPath 表达式来从 JSON 数据中提取信息的。JSONPath 是一种类似于 XPath 的查询语言用于从 JSON 结构中选择和提取数据。让我一步步解释这段代码的含义 ${bkCargo:jsonPath($[?(.cargoFlag in [M])])}: 这部分的含义是从一个名为 bkCargo 的 JSON 对象中使用 JSONPath 查询筛选出具有 cargoFlag 属性值为 M 的元素。换句话说这部分代码会返回一个包含满足条件的货物的数组或集合。 :jsonPath($.noOfPackage): 这部分的含义是在上一步得到的满足条件的货物数组中再次使用 JSONPath 查询提取每个货物元素的 noOfPackage 属性值即货物的包裹数量。
综合起来整个代码的目的是从名为 bkCargo 的 JSON 数据中选取具有 cargoFlag 属性值为 M 的货物并且提取这些货物的包裹数量noOfPackage 属性值。最终这段代码将会返回一个包含满足条件货物的包裹数量的数组或集合。 问题8数据分流合并数据 8.1 初始化分段合并所需参数
infosp.count 2 infosp.identifier ${UUID()} 8.2 设置分段合并所需参数1
infosp.index 1 8.2 设置分段合并所需参数2
infosp.index 2 8.3 设置复原infosp分段参数
fragment.count ${infosp.count} fragment.identifier ${infosp.identifier} fragment.index ${infosp.index} 问题9多条件判断
dict.运输条款END2等于CY的时候等于Y
dict.运输条款END2等于CFS的时候等于S
dict.运输条款END2等于DOOR的时候等于D
${dict.运输条款END2:equals(CY):ifElse(Y, ${dict.运输条款END2:equals(CFS):ifElse(S, ${dict.运输条款END2:equals(DOOR):ifElse(D, )})})}
