Nifi功能

Nifi操作Redis

简介

Nifi操作Redis,需要通过服务的形式,其流程非常简单,创建服务——>创建处理器——>测试

服务

RedisConnectionPoolService

该控制器服务用来链接到Redis,并控制链接参数

RedisDistributedMapCacheClientService

控制器

PutDistributedMapCache
FetchDistributedMapCache

案例

通用步骤

通用步骤指的是读写Redis都需要执行的操作,其实就是创建链接Redis服务,注意,通用步骤必须要做,否则后面的读写Redis步骤必然失败

1.在画布上右击,选择Configure,在打开的窗口中选择CONTROLLER SERVICES选项卡,点击右上角的加号

2.在打开的窗口中搜索添加RedisDistributedMapCacheClientServiceRedisConnectionPoolService服务

3.首先配置RedisConnectionPoolService服务,点击最右侧的小齿轮(在闪电左边的那个)

4.然后配置RedisDistributedMapCacheClientService服务,也是点击右边的小齿轮


5.点击RedisConnectionPoolService服务右侧的小闪电(启动),以启动服务


如果最后显示如下,不显示黄色感叹号,即代表配置服务成功!(注意,最好等5-10秒,Nifi错误信息可能持续一小会)关闭此窗口即可!

写Redis

1.创建完成服务后,回到画布创建一个ListenHTTP控制器和一个PutDistributedMapCache控制器,其中ListenHTTP控制器用来接受值,并传入PutDistributedMapCache控制器,由它写入Redis


ListenHTTP控制器属性

PutDistributedMapCache控制器属性

PutDistributedMapCache控制器首先要配置一下SETTINGS页面的内容(因为它是最终的控制器,要结束数据流)

然后配置它的属性

2.选中它们,点击启动

3.通过Postman测试接口

到Redis客户端中查看结果

读取Redis

1.读Redis的方法更加简单,我们在写Redis的基础上继续增加两个处理器(FetchDistributedMapCacheLogAttribute

2.其中,FetchDistributedMapCache的属性设置为:

3.LogAttribute也需要进行结束流的配置:

4.目前我们可以不对LogAttribute进行配置,直接启动你的控制器即可!

5.和之前测试写Redis一样,在Postman中调用我们的接口即可

6.在你的Nifi根目录下会有一个log文件夹,其中有一个nifi-app.log文件,打开,将滚动条拉倒最后,有如下内容即代表成功!

Nifi操作Redis相关推荐

  1. 30 个 php 操作 redis 常用方法代码例子

    这篇文章主要介绍了 30 个 php 操作 redis 常用方法代码例子 , 本文其实不止 30 个方法 , 可以操作 string 类 型. list 类型和 set 类型的数据 , 需要的朋友可以 ...

  2. java 操作 redis_java操作Redis

    10. java操作Redis 10.1 环境准备 1. 引入依赖 redis.clients jedis 2.9.0 2.创建jedis对象 package org.example; import ...

  3. 还在直接操作 Redis?赶快来试试这个

    以下文章来源方志朋的博客,回复"666"获面试宝典 有些人还在直接用Jedis操作Redis数据库,但这种方式非常不方便,而且很不灵活.用Spring Boot整合Redis之后, ...

  4. 自己动手写一个能操作redis的客户端

    作者:孤独烟 来自:http://rjzheng.cnblogs.com/ 引言 redis大家在项目中经常会使用到.官网也提供了多语言的客户端供大家操作redis,如下图所示 但是,大家有思考过,这 ...

  5. redis缓存失效时间设为多少_java操作Redis缓存设置过期时间的方法

    关于Redis的概念和应用本文就不再详解了,说一下怎么在java应用中设置过期时间. 在应用中我们会需要使用redis设置过期时间,比如单点登录中我们需要随机生成一个token作为key,将用户的信息 ...

  6. jedis操作set_Java中使用Jedis操作Redis的示例代码

    使用java操作Redis需要jedis-2.1.0.jar,下载地址:jedis-2.1.0.jar 如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar,下载地址:c ...

  7. 使用Spring操作Redis的key-value数据

    前言 最近工作一直忙的不可开交,小Alan已经很久没有和大家分享知识了,在深圳待了两年多,依然感觉自己还是个小菜鸟,工作中还是会遇到很多自己在短期内无法搞定的事情,每当这个时候总是会感觉到很沮丧,就会 ...

  8. Python操作Redis及连接方式

    前沿:随着互联网的高速发展,数据变得越来越重要,Python成为了人工智能的热门语言,而Nosql数据库已成为日常开发用品. 今天要写的是Python操作Redis Redis的安装我就不介绍了,你可 ...

  9. Jedis操作Redis数据库

    添加Maven依赖: 1 <dependencies> 2 <!-- 单元测试 --> 3 <dependency> 4 <groupId>junit& ...

  10. python 操作redis之——有序集合(sorted set) (七)

    #coding:utf8 import redis r =redis.Redis(host="23.226.74.190",port=63279,password="66 ...

最新文章

  1. 禅道项目管理软件介绍
  2. VISP视觉库识别AprilTag详细解读
  3. 调取方法_转需!不去阿里巴巴调取支付宝交易证据方法
  4. 笔记-高项案例题-2018年上-质量管理
  5. 学习 TTreeView [8] - AlphaSort、CustomSort、SortType
  6. angular 绑定自定义属性_Angular2实现自定义双向绑定属性
  7. 开源中国 OsChina Android 客户端源码分析(7)二维码生成对话框
  8. java hashmap遍历顺序_Java中HashMap遍历的两种方式
  9. pythonjava解释xml_Python解析XML文档
  10. Revit二次开发The symbol is not active
  11. 恢复SQLSERVER被误删除的数据(转——收藏)
  12. python永久保存数据_Python学习笔记(四)——文件永久存储
  13. PostgreSQL on Linux 最佳部署指南
  14. 滴滴接盘小蓝单车,押金问题谁来负责?
  15. 【2020团体程序设计天梯赛】L2部分(PTA,L2-033到L2-036)题解代码复盘
  16. U3D AND UDK 各自特点
  17. 工业视觉_57:霍夫(Hough)直线识别,交点与夹角
  18. Maven报错Original error: Could not transfer artifact
  19. weblogic相关问题
  20. 网络封包分析软件-wireshark

热门文章

  1. SOCKS5协议的原理和应用
  2. 微分方程模型_常微分方程模型简介
  3. 高通 MSM 8916与MSM8926芯片的区别
  4. 哪个搜索引擎干净?无追踪无监控且保护用户隐私安全的小众搜索引擎推荐
  5. python房屋租赁管理系统设计与实现报告_基于JavaWeb的房屋出租管理系统设计与实现毕业论文+开题报告+项目源码...
  6. LAMP兄弟连 视频教程集
  7. EDEM及Fluent的耦合
  8. Hikari 数据库连接池配置详解
  9. 一文搞懂CAN总线协议帧格式
  10. 24个笔画顺序表田字格_PPT 笔画书写动画,这样可以快速制作哦