社区微信群开通啦，扫一扫抢先加入社区官方微信群
社区微信群
Nifi操作Redis，需要通过服务的形式，其流程非常简单，创建服务——>创建处理器——>测试
该控制器服务用来链接到Redis，并控制链接参数
通用步骤指的是读写Redis都需要执行的操作，其实就是创建链接Redis服务，注意，通用步骤必须要做，否则后面的读写Redis步骤必然失败
1.在画布上右击，选择Configure，在打开的窗口中选择CONTROLLER SERVICES选项卡，点击右上角的加号
2.在打开的窗口中搜索添加RedisDistributedMapCacheClientService和RedisConnectionPoolService服务
3.首先配置RedisConnectionPoolService服务，点击最右侧的小齿轮（在闪电左边的那个）
4.然后配置RedisDistributedMapCacheClientService服务，也是点击右边的小齿轮
5.点击RedisConnectionPoolService服务右侧的小闪电（启动），以启动服务
如果最后显示如下，不显示黄色感叹号，即代表配置服务成功！（注意，最好等5-10秒，Nifi错误信息可能持续一小会）关闭此窗口即可！
1.创建完成服务后，回到画布创建一个ListenHTTP控制器和一个PutDistributedMapCache控制器，其中ListenHTTP控制器用来接受值，并传入PutDistributedMapCache控制器，由它写入Redis
ListenHTTP控制器属性
PutDistributedMapCache控制器属性
PutDistributedMapCache控制器首先要配置一下SETTINGS页面的内容（因为它是最终的控制器，要结束数据流）
然后配置它的属性
2.选中它们，点击启动
3.通过Postman测试接口
到Redis客户端中查看结果
1.读Redis的方法更加简单，我们在写Redis的基础上继续增加两个处理器（FetchDistributedMapCache和LogAttribute）
2.其中，FetchDistributedMapCache的属性设置为：
3.LogAttribute也需要进行结束流的配置：
4.目前我们可以不对LogAttribute进行配置，直接启动你的控制器即可！
5.和之前测试写Redis一样，在Postman中调用我们的接口即可
6.在你的Nifi根目录下会有一个log文件夹，其中有一个nifi-app.log文件，打开，将滚动条拉倒最后，有如下内容即代表成功！
如果觉得我的文章对您有用，请随意打赏。你的支持将鼓励我继续创作！
