Apache nifi 第一篇(概述)

Apache nifi 第二篇(小白初试) nifi数据对接流程初次尝试

NIFI ExecuteSQL配置教程(1.8)

Processor(处理器)之配置

Apache NiFi Processor实战

Cron表达式一些范例

每隔5秒执行一次:/5 * * * ?

每隔1分钟执行一次:0 /1 * * ?

每天23点执行一次:0 0 23 * * ?

每天凌晨1点执行一次:0 0 1 * * ?

每月1号凌晨1点执行一次:0 0 1 1 * ?

每月最后一天23点执行一次:0 0 23 L * ?

每周星期天凌晨1点实行一次:0 0 1 ? * L

在26分、29分、33分执行一次:0 26,29,33 * * * ?

每天的0点、13点、18点、21点都执行一次:0 0 0,13,18,21 * * ?
————————————————
版权声明:本文为CSDN博主「温码」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/born_mad/article/details/78065388

cron 表达式0 0/10 * * * 与 0 */10 * * *的区别

Penalization vs. Yielding

当在处理过程中出现问题时,框架公开了两种方法,允许处理器开发人员避免执行不必要的工作:“惩罚”和“屈服”。对于刚接触NiFi API的开发人员来说,这两个概念可能会让人感到困惑。开发人员可以通过调用来惩罚FlowFilepenalize(FlowFile)ProcessSession的方法。这导致FlowFile本身在一段时间内无法访问下游处理器。FlowFile不可访问的时间由DataFlow Manager通过在Processor Configuration对话框中设置“Penalty Duration”设置来确定。默认值为30秒。通常,这是在处理器确定由于预期将自己排序的环境原因而无法处理数据时完成的。一个很好的例子是PutSFTP处理器,如果SFTP服务器上已存在具有相同文件名的文件,它将惩罚FlowFile。在这种情况下,处理器会惩罚FlowFile并将其路由到失败。然后,DataFlow Manager可以将故障路由回相同的PutSFTP处理器。这样,如果文件存在相同的文件名,处理器不会再次尝试发送文件30秒(或DFM配置处理器使用的任何时间段)。与此同时,它能够继续处理其他FlowFiles。

另一方面,让步允许处理器开发人员向框架指示它将在一段时间内不能执行任何有用的功能。这通常发生在与远程资源通信的处理器上。如果处理器无法连接到远程资源,或者如果远程资源需要提供数据但报告它没有,则处理器应调用yieldProcessContext对象然后返回。通过这样做,处理器告诉框架它不应该浪费资源来触发此处理器运行,因为它无法做任何事情 - 最好使用这些资源来允许其他处理器运行。

最新文章

  1. 简析Geoserver中获取图层列表以及各图层描述信息的三种方法
  2. Hello Spring Framework——依赖注入(DI)与控制翻转(IoC)
  3. Entity Framework4.0 (一)概述(EF4 的Database First方法)
  4. POJ 3254 Corn Fields(状压DP)
  5. windows 2008R2 无法安装操作系统补丁,或无法安装Sp1升级包的解决办法
  6. Linux_搜文件
  7. Java内存结构、类的初始化、及对象构造过程
  8. strtotime的几种用法区别
  9. iOS 处理方法中的可变參数
  10. Java IO面试
  11. python函数调用的四种方式 --基础重点
  12. 基于Log4Net本地日志服务简单实现
  13. PHP基础入门(五)---PHP面向对象实用基础知识
  14. 通过nginx中转获取不到IP的问题解决
  15. PHP获取手机号
  16. ros 使用python代码启动launch文件
  17. UTF-8以字节为单位对Unicode进行编码
  18. WPF:ComboBox使用XmlDataProvider做级联
  19. opencv+opencv_contrib 人脸识别和检测 python开发环境快速搭建(30分钟)图文教程
  20. VT-x VT-d 虚拟化在win10中的问题

热门文章

  1. 支持USB4的Linux 5.6,有望在今年4月份推出
  2. 问题解决 : MyBatis一对一查询时,打印结果只有一条数据
  3. python3 使用selenium +webdriver打开chrome失败,报错:FileNotFoundError: [Errno 2] No such file or directory: 'chromedriver': 'chromedriver'
  4. JavaScript内置对象Array、String 的方法
  5. rally问题合集
  6. redis学习笔记-03:redis安装
  7. 三级联动下拉列表——php 、Ajax
  8. 十二 事务&安全问题&隔离级别
  9. hibernate部分源码解析and解决工作上关于hibernate的一个问题例子(包含oracle中新建表为何列名全转为大写且通过hibernate取数时如何不用再次遍历将列名(key)值转为小写)
  10. JavaScript 词法句法