PutRedisHashRecord

PutRedisHashRecord Processor

类型全限定名：cn.org.acal.lynxus.redis.processor.PutRedisHashRecord

所属 Bundle：cn.org.acal.lynxus:lynxus-redis-nar:2.11.8

描述

使用指定的哈希值将记录字段数据放入 Redis，该哈希值由包含哈希值的每个记录中的字段的 RecordPath 确定。记录字段和值存储为与哈希值关联的键/值对。注意：计算的哈希值和任何字段值都不能为空。如果hash值为null，则FlowFile将被路由至失败。对于每个字段值，如果值为 null，则不会在 Redis 中设置该字段。

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Record Reader		控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于解析传入数据并确定数据模式的 Controller Service
Redis Connection Pool		控制器服务 API： `RedisConnectionPool` cn.org.acal.lynxus-lynxus-redis-service-api-nar-2.11.8
Hash Value Record Path			指定一个 RecordPath，对每条记录进行求值以确定与所有记录字段/值关联的哈希值（有关更多详细信息，请参阅 Redis 文档中的 'hset'）。RecordPath 必须恰好指向一个字段，否则将发生错误。
数据记录路径	`/`		此属性表示将对每个传入记录求值的 RecordPath，求值 RecordPath 得到的记录将发送到 Redis，而不是发送整个传入记录。属性默认为根 '/'，对应于'平面'记录（所有字段/值在记录的顶层）。
Character Set	`UTF-8`		指定在将记录字段值存储为字符串时使用的字符集。所有字段都将使用此字符集转换为字符串后再存储到 Redis 中。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）

关系 (Relationships)

名称	描述	自动终止
`failure`	包含有处理错误的记录的FlowFile将被路由到此关系	否
`success`	具有存储在 Redis 中的所有记录的 FlowFile 将被路由到此关系	否

写入的 FlowFile 属性

名称	描述
`redis.success.record.count`	写入 Redis 的记录数

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。