Nifi操作Redis
Nifi功能
Nifi操作Redis
简介
Nifi操作Redis,需要通过服务的形式,其流程非常简单,创建服务——>创建处理器——>测试
服务
RedisConnectionPoolService
该控制器服务用来链接到Redis,并控制链接参数
RedisDistributedMapCacheClientService
控制器
PutDistributedMapCache
FetchDistributedMapCache
案例
通用步骤
通用步骤指的是读写Redis都需要执行的操作,其实就是创建链接Redis服务,注意,通用步骤必须要做,否则后面的读写Redis步骤必然失败
1.在画布上右击,选择Configure
,在打开的窗口中选择CONTROLLER SERVICES
选项卡,点击右上角的加号
2.在打开的窗口中搜索添加RedisDistributedMapCacheClientService
和RedisConnectionPoolService
服务
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的基础上继续增加两个处理器(FetchDistributedMapCache
和LogAttribute
)
2.其中,FetchDistributedMapCache
的属性设置为:
3.LogAttribute
也需要进行结束流的配置:
4.目前我们可以不对LogAttribute
进行配置,直接启动你的控制器即可!
5.和之前测试写Redis一样,在Postman中调用我们的接口即可
6.在你的Nifi根目录下会有一个log文件夹,其中有一个nifi-app.log
文件,打开,将滚动条拉倒最后,有如下内容即代表成功!
Nifi操作Redis相关推荐
- 30 个 php 操作 redis 常用方法代码例子
这篇文章主要介绍了 30 个 php 操作 redis 常用方法代码例子 , 本文其实不止 30 个方法 , 可以操作 string 类 型. list 类型和 set 类型的数据 , 需要的朋友可以 ...
- java 操作 redis_java操作Redis
10. java操作Redis 10.1 环境准备 1. 引入依赖 redis.clients jedis 2.9.0 2.创建jedis对象 package org.example; import ...
- 还在直接操作 Redis?赶快来试试这个
以下文章来源方志朋的博客,回复"666"获面试宝典 有些人还在直接用Jedis操作Redis数据库,但这种方式非常不方便,而且很不灵活.用Spring Boot整合Redis之后, ...
- 自己动手写一个能操作redis的客户端
作者:孤独烟 来自:http://rjzheng.cnblogs.com/ 引言 redis大家在项目中经常会使用到.官网也提供了多语言的客户端供大家操作redis,如下图所示 但是,大家有思考过,这 ...
- redis缓存失效时间设为多少_java操作Redis缓存设置过期时间的方法
关于Redis的概念和应用本文就不再详解了,说一下怎么在java应用中设置过期时间. 在应用中我们会需要使用redis设置过期时间,比如单点登录中我们需要随机生成一个token作为key,将用户的信息 ...
- 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 ...
- 使用Spring操作Redis的key-value数据
前言 最近工作一直忙的不可开交,小Alan已经很久没有和大家分享知识了,在深圳待了两年多,依然感觉自己还是个小菜鸟,工作中还是会遇到很多自己在短期内无法搞定的事情,每当这个时候总是会感觉到很沮丧,就会 ...
- Python操作Redis及连接方式
前沿:随着互联网的高速发展,数据变得越来越重要,Python成为了人工智能的热门语言,而Nosql数据库已成为日常开发用品. 今天要写的是Python操作Redis Redis的安装我就不介绍了,你可 ...
- Jedis操作Redis数据库
添加Maven依赖: 1 <dependencies> 2 <!-- 单元测试 --> 3 <dependency> 4 <groupId>junit& ...
- python 操作redis之——有序集合(sorted set) (七)
#coding:utf8 import redis r =redis.Redis(host="23.226.74.190",port=63279,password="66 ...
最新文章
- 禅道项目管理软件介绍
- VISP视觉库识别AprilTag详细解读
- 调取方法_转需!不去阿里巴巴调取支付宝交易证据方法
- 笔记-高项案例题-2018年上-质量管理
- 学习 TTreeView [8] - AlphaSort、CustomSort、SortType
- angular 绑定自定义属性_Angular2实现自定义双向绑定属性
- 开源中国 OsChina Android 客户端源码分析(7)二维码生成对话框
- java hashmap遍历顺序_Java中HashMap遍历的两种方式
- pythonjava解释xml_Python解析XML文档
- Revit二次开发The symbol is not active
- 恢复SQLSERVER被误删除的数据(转——收藏)
- python永久保存数据_Python学习笔记(四)——文件永久存储
- PostgreSQL on Linux 最佳部署指南
- 滴滴接盘小蓝单车,押金问题谁来负责?
- 【2020团体程序设计天梯赛】L2部分(PTA,L2-033到L2-036)题解代码复盘
- U3D AND UDK 各自特点
- 工业视觉_57:霍夫(Hough)直线识别,交点与夹角
- Maven报错Original error: Could not transfer artifact
- weblogic相关问题
- 网络封包分析软件-wireshark
热门文章
- SOCKS5协议的原理和应用
- 微分方程模型_常微分方程模型简介
- 高通 MSM 8916与MSM8926芯片的区别
- 哪个搜索引擎干净?无追踪无监控且保护用户隐私安全的小众搜索引擎推荐
- python房屋租赁管理系统设计与实现报告_基于JavaWeb的房屋出租管理系统设计与实现毕业论文+开题报告+项目源码...
- LAMP兄弟连 视频教程集
- EDEM及Fluent的耦合
- Hikari 数据库连接池配置详解
- 一文搞懂CAN总线协议帧格式
- 24个笔画顺序表田字格_PPT 笔画书写动画,这样可以快速制作哦