代码之家  ›  专栏  ›  技术社区  ›  Kannan Ramamoorthy

将nifi web api bean注入定制处理器

  •  0
  • Kannan Ramamoorthy  · 技术社区  · 7 年前

    我在玩NiFi定制处理器。 如何注入 org.apache.nifi.web.StandardNiFiServiceFacade

    背景:

    我正在尝试实现在处理器执行后停止处理器的目标。我知道nifi处理器只用于流处理,不用于批处理,在批处理中我们只执行一次作业。但要利用NiFi的执行支持,需要这样做。随着实验的深入,我将能够在 StandardNiFiServiceFacade

    2 回复  |  直到 7 年前
        1
  •  6
  •   Joe Witt    7 年前

    这不是故意提供给处理器API的。如果您确定要让处理器告诉控制器停止调度它,那么它可以像对用户界面或编程API调用那样对API进行HTTP/restapi调用。

        2
  •  2
  •   mattyb    7 年前

    如果您是从上游处理器(如GenerateFlowFile)触发此自定义处理器,则可以利用ExecuteScript模拟“one and done”作业触发器,请签出 my blog post 对于Groovy脚本,它可能会帮助您实现所要做的事情。