Nifi 模板
2016-06-03 17:30
525 查看
collect-stream-logs
This flow shows workflow for log collection, aggregation, store and display.Ingest logs from folders.
Listen for syslogs on UDP port.
Merge syslogs and drop-in logs and persist merged logs to Solr for historical search.
Dashboard: stream real-time log events to dashboard and enable cross-filter search on historical logs data.
csv-to-json
This flow shows how to convert a CSV entry to a JSON document using ExtractText and ReplaceText.decompression
This flow demonstrates taking an archive that is created with several levels of compression and then continuously decompressing it using a loop until the archived file is extracted out.http-get-route
his flow pulls from a web service (example is nifi itself), extracts text from a specific section, makes a routing decision on that extracted value, prepares to write to disk using PutFile.invoke-http-route
This flow demonstrates how to call an HTTP service based on an incoming FlowFile, and route the original FlowFile based on the status code returned from the invocation. In this example, every 30 seconds a FlowFile is produced, an attribute is added to the FlowFile that sets q=nifi, the google.com is invoked for that FlowFile, and any response with a 200 is routed to a relationship called 200.retry-count-loop
This process group can be used to maintain a count of how many times a flowfile goes through it. If it reaches some configured threshold it will route to a 'Limit Exceeded' relationship otherwise it will route to 'retry'. Great for processes which you only want to run X number of times before you give up.split-route
This flow demonstrates splitting a file on line boundaries, routing the splits based on a regex in the content, merging the less important files together for storage somewhere, and sending the higher priority files down another path to take immediate action.twitter-garden-hose
This flow pulls from Twitter using the garden hose setting; it pulls out some basic attributes from the Json and then routes only those items that are actually tweets.twitter-solr
This flow shows how to index tweets with Solr using NiFi. Pre-requisites for this flow are NiFi 0.3.0 or later, the creation of a Twitter application, and a running instance of Solr 5.1 or later with a tweets collection. Here are sample steps to set this up (along with Banana dashboard) on HDP Sandbox.NIFI 中国社区 QQ群：595034369
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- java三方---->html解析jsoup的使用
- iOS开发UI篇—Quartz2D使用(信纸条纹)
- cocos2dx[3.x](3)——大巨变3.x
- Unity3D中自带事件函数的执行顺序
- 实战记录：从EclipseLink迁移到Hibernate上（1）替换
- 勤奋是一条通往成功的路——阿尔卡特-朗讯测试架构师 郑文强
- 如何在arxiv上发论文
- 修复关于apache-xampp的问题：Port 443 in use by “vmware-hostd.exe”!
- GL_BOOK_5
- 嵌入式Linux ARM汇编（一）——ARM体系结构
- 服务器安装MongoDB
- SQL SERVER 中如何用脚本管理作业
- Crontab定时任务配置
- OpenCAPWAP多线程介绍
- Excel数据提取C++代码（仅供参考）
- Java中的IO笔记Mars
- Q1010 Tempter of the Bone C++ （深度优先搜索）
- Android项目笔记六：自定义的wificlass
- unity3d KeyCode各键值说明
- 【Leetcode】287. Find the Duplicate Number My Submissions QuestionEditorial Solution python实现