PutRedisHashRecord 2025.5.31.15

捆绑包

org.apache.nifi | nifi-redis-nar

描述

使用指定的哈希值将记录字段数据放入 Redis,该哈希值由包含哈希值的每个记录中的字段的 RecordPath 确定。记录字段和值存储为与哈希值关联的键/值对。NOTE:评估的哈希值和任何字段值都不能为空。如果哈希值为空,则 FlowFile 会路由到 failure。对于每个字段值,如果该值为空,则不会在 Redis 中设置该字段。

标签

hash、put、record、redis

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

字符集

指定将记录字段值存储为字符串时使用的字符集。在存储在 Redis 中之前,所有字段都将使用此字符集转换为字符串。

data-record-path

此属性表示将根据每条传入记录进行评估的 RecordPath,而评估 RecordPath 得到的记录将发送到 Redis,而不是发送整个传入记录。该属性默认值为根“/”,对应于“扁平”记录(记录顶层的所有字段/值)。

hash-value-record-path

指定要对每条记录进行评估的 RecordPath,以确定与所有记录字段/值关联的哈希值(有关更多详细信息,请参阅 Redis 文档中的“hset”)。RecordPath 必须正好指向一个字段,否则会出现错误。

record-reader

指定用于解析传入数据和确定数据架构的控制器服务

redis-connection-pool

关系

名称

描述

failure

包含带有处理错误的记录的 FlowFiles 将路由到此关系

success

将所有记录存储在 Redis 中的 FlowFiles 将路由到此关系

写入属性

名称

描述

redis.success.record.count

写入到 Redis 的记录数

语言: 中文