Skip to main content

PutDistributedMapCache

将输入数据流内容写入到Redis缓存中，且使用缓存键属性。如何缓存中已经包含，且缓存更新策略为“保留原始” ，则将不做替换

参数说明​

缓存实体键​

指定写入数据实体的缓存键，可以是数据流属性或者是一个表达式

缓存服务​

指定用于缓存数据流的控制器服务DistributedMapCacheClient

更新策略​

指定如何更新缓存中实体内容的策略

  • 替换
  • 保留原始

缓存大小​

设置放入缓存的数据最大数量

输出连线​

  • failure连线表示不能写入Redis缓存的数据流输出
  • success连线表示成功写入到Redis缓存的数据流输出

示例​

GenerateFlowFile配置​

为避免生成过多数据，将组件”调度“中的”运行安排“设置为7 days。

再将”自定义文本“设置为：

{
"sname":"jack",
"id":"00001",
"state":"NY"
}

流程说明​

在此流程中会通过将JSON数据作为缓存值写入到Redis中,需要注意，除了在组件中设置缓存的客户端控制器服务，还需要在模板的配置页面中新增一个DistributedMapCacheServer服务端控制器服务

FetchDistributedMapCache设置​

以缓存JSON为例，设置了缓存实体键为id_cache，缓存服务为DistributedMapCacheClientService控制器服务，更新策略为替换，缓存大小为1MB。

结果​

最后输出结果如下：

  • success连线输出结果

流程模板​

参见附件(请右键另存保存)：模板文件