ETL工具-nifi干货系列 第十七讲 nifi Input PortOut Port 实战教程

embedded/2025/1/15 8:03:40/

1、端口(Port),包含输入端口(Input Port)和输出端口(Out Port )

使用一个或多个处理组构建的数据流需要一种方式将处理组连接到其他数据流组件。

处理组和处理组之间可以通过使用端口来进行连接。这里的端口和kettle中的步骤【复制记录到结果】、【从结果获取记录】是类似的功能。

数据流管理者可以向处理组添加任意数量的输入端口和输出端口(1个或者多个),并适当地命名这些端口。

上图设计处理组【用户信息表同步】流向处理组【交易订单表同步】

处理组【用户信息表同步】中添加一个Out Port。

处理组【交易订单表同步】中添加一个Input Port。

拖动处理组【用户信息表同步】➡️标记至处理组【交易订单表同步】,两个处理组直接进行关联。

假若一个处理组中有多个Input/Out Port的话,拖动➡️进行关联时会弹出关联选择窗体,如下图所示:

2、添加Out Port

双击Process Group进入处理组中。

从顶部工具栏拖动Out Port至画布。

设置处理器至Out Port的连线。

Out Port Name:自定义输出端口名称

Send To:数据流发送目的地选项,有Local connections,Remote connections (site-to-site)两个选项。

Local connections属于同一个nifi实例之间的数据流传输。

Remote connections (site-to-site):不同nifi实例之间的数据流传输。

3、添加Input Port

双击Process Group进入处理组中。

从顶部工具栏拖动Input Port至画布。

设置Input Port至处理器的连线。

Input Port Name:自定义输入端口名称

Receive From:数据流来源的选项,有Local connections,Remote connections (site-to-site)两个选项。

Local connections属于同一个nifi实例之间的数据流传输。

Remote connections (site-to-site):不同nifi实例之间的数据流传输。

 4、点击运行nifi 数据流,进入处理组查看溯源信息,如下图所示:


http://www.ppmy.cn/embedded/14576.html

相关文章

绿色便携方式安装apache+mysql+tomcat+php集成环境并提供控制面板

绿色便携方式安装带控制面板的ApacheMariaDBTomcatPHP集成环境 目录 绿色便携方式安装带控制面板的ApacheMariaDBTomcatPHP集成环境[TOC](目录) 前言一、XAMPP二、安装和使用1.安装2.使用 三、可能的错误1、检查端口占用2、修改端口 前言 安装集成环境往往配置复杂&#xff0c…

如何查看连接的Linux服务器是ubuntu还是centos

测试环境 Ubuntu 22.04.4CentOS Linux release 7.9.2009 (Core) centos使用以下命令 cat /etc/centos-release结果 CentOS Linux release 7.9.2009 (Core)或者 cat /etc/issue结果 \S Kernel \r on an \mubuntu使用以下命令 cat /etc/issue结果 Ubuntu 22.04.4 LTS \n …

【Python-编程模式】

Python-编程模式 ■ 单例模式■ 工厂模式■■ ■ 单例模式 新建文件 str_tools.py 如下代码。 class StrTools:passstr_tool StrTools()在其他文件使用时导入该变量。 from str_tools_py import str_tool s1 str_tool s2 str_tool print(id(s1)) print(id(s2))■ 工厂模式…

Android IPC | Android多进程模式

前 言 关于Android的进程间通信(即IPC)有很多种方式,比如我们常用的AIDL、Socket等,而其中最重要而且最需要掌握的就是AIDL的使用和原理,简单来说它是通过Binder实现的。 关于Binder的知识点非常多,当我们…

酷开科技生态内容价值+酷开系统的开放性和可塑性,实现品效合一

互联网浪潮之下,电视行业也迎来了新的机遇和挑战,酷开科技坚持以用户为中心,想用户所想,急用户所急,抓核心科技,为消费者提供优质、便捷的产品和服务,切实解决用户电视使用痛点,得到…

vue项目的Husky、env、editorconfig、eslintrc、tsconfig.json配置文件小聊

一、Git配置文件 1、Husky Husky 是一款管理 git hooks 的工具,可以帮助我们触发git提交的各个阶段:pre-commit、commit-msg、pre-push, 有助于我们在项目开发中的git规范和团队协作。 .husky文件通常包含以下内容: pre-commi…

基于RK3588的全国产鸿蒙边缘计算工控机在智能交通ETC收费系统的应用

1.1 产品简介 基于智能交通、工业互联等行业快速智能化发展的需求,以 OpenHarmony 为框架开发嵌入 HamonyOS,打造了具有高智能、高可靠、高安全的自主 可控的边缘处理器 XM-RK3588。 图 1-1 边缘处理器 HamonyOS强化 IoT 互联互动能力,让边缘…

Xbar控制图的定义和应用

1、定义 Xbar控制图(X-Bar Chart)是一种统计图表,用于展示数据分布情况。它通过绘制一系列数据点在均值线(通常为X轴)周围的分布情况来显示数据的波动性。这种图表可以用来监控生产过程、质量管理、金融分析等多个领域…