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

news2024/10/5 23:15:54

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.coloradmin.cn/o/1622211.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

<网络> HTTP

目录 前言: 一、再谈协议 (一)认识URL (二)Encode 和 Decode 二、HTTP 协议 (一)协议格式 (二)见一见请求 (三)见一见响应 三、模拟实现响…

github Copilot的使用总结

1. 代码建议和补全 GitHub Copilot 的基本使用涉及编写代码时的实时代码建议和补全。一旦你已经安装并配置好 GitHub Copilot 插件,你可以在支持的编辑器(如 Visual Studio Code)中开始使用 Copilot。以下是一些基本的使用步骤: …

hadoop文件操作代码实现

hadoop文件操作 目录 一、文件的上传 删除 查看 1.整体代码 2.代码运行 3.查看证实 4.具体代码解析 1)向Hadoop传文件 2)向本地Windows传文件 3)删除Hadoop的文件 4)判断文件是否存在 二、列出文件 1.整体代码 2.代码…

代码随想录算法训练营Day8 | ● 344.反转字符串● 541. 反转字符串II● 54.替换数字● 151.翻转字符串里的单词● 55.右旋转字符串

(记得重学) ● 344.反转字符串 题目:编写一个函数,其作用是将输入的字符串反转过来。输入字符串以字符数组 s 的形式给出。 不要给另外的数组分配额外的空间,你必须原地修改输入数组、使用 O(1) 的额外空间解决这一…

Unity 异常 bug

OverlapBoxNonAlloc 使用bug 环境: Unity2021.3.15 在测试场景中使用 OverlapBoxNonAlloc 测试检测没有问题 但是到了真实应用场景,使用 OverlapBoxNonAlloc 检测移动中的小怪 小怪碰撞体为:带有 Rigidbody 的Circle Collider 2D 就会出现异…

RustGUI学习(iced)之小部件(二):如何使用滑动条部件

前言 本专栏是学习Rust的GUI库iced的合集,将介绍iced涉及的各个小部件分别介绍,最后会汇总为一个总的程序。 iced是RustGUI中比较强大的一个,目前处于发展中(即版本可能会改变),本专栏基于版本0.12.1. 概述…

力扣HOT100 - 994. 腐烂的橘子

解题思路: 因为要记录轮数(分钟数),所以不能一口气遍历到底,所以不能用深搜(bfs),而要用广搜(bfs,层序遍历)。 先记录下新鲜橘子数,…

MyBatis Dynamic SQL基本使用

MyBatis Dynamic SQL基本使用 一、概念二、特性Hamcrest是什么 三、MyBatis Dynamic SQL 快速入门3.1 环境准备3.2 定义表和列3.3 创建 MyBatis3 映射器3.4 使用 MyBatis3 执行 SQL 四、数据库对象表示4.1 表或视图表示4.2 表别名4.3 列表示 五、Where 子句支持5.1 简单的 wher…

什么样的文件传输调度产品 可以简化IT工作流程?

文件传输调度是企业数据管理中的一个重要环节,企业在存在多个分支机构、子公司,或者多个数据中心、服务器节点的时候,都会需要进行文件传输调度,在使用传统的FTP、rsync等传输方式在应对这些复杂的文件交换需求时,会存…

C语言趣味代码(三)

这一篇主要围绕写一个程序---寻找数字 来写,在这篇我会详细和大家介绍基本实现以及它的改良版,还有相关知识的拓展,干货绝对满满。 1. 寻找数字 在这一主题下,我们会编写一些代码,来锻炼玩家的反应力,同时…

让外贸客户心甘情愿下单的话术分享

学会这些话术,轻松拿捏客户,让客户心甘情愿下单 一、客户喜欢讨价还价的模板旨在帮助外贸人员在与客户讨价还价时,既能坚持自己的立场,又能体现出专业和诚信的态度。 二、客户犹豫要不要下单的贸易话术旨在帮助客户消除疑虑&#…

Spring Boot 源码--SpringApplication#run 方法源码解析

前言: 开发过 Spring Boot 项目的都知道只需要一个简单的入口类,然后入口类中有个 main 方法,main 方法中调用了 SpringApplication.run 方法,再配合 SpringBootApplication 注解就可以完成一个项目的启动,如下&#…

云打印怎么上传文件?云打印怎么把文件发送给商家?

随着云打印的火热,现在很多同学们都选择云打印服务来打印自己的资料文档。但是云打印服务毕竟要隔着网络打印,那么我们应该怎么上传文件呢?云打印怎么把文件发送给商家呢?今天小易就带大家一起来了解一下。 云打印怎么上传文件&am…

python爬虫之xpath4

1 最终项目实现的代码 仙剑 #!/usr/bin/env python ​ import logging import requests import re from urllib.parse import urljoin import pymongo import multiprocessing ​ mongo_client pymongo.MongoClient("mongodb://192.168.135.131:27017/") db mong…

【禅道客户案例】专访鸿泉物联研发副总监徐小倩,感受上市公司研发项目管理“知与行”

杭州鸿泉物联网技术股份有限公司(以下简称“鸿泉物联”、“公司”)成立于2009年6月11日,2019年11月6日登陆上海证券交易所科创板(股票代码:688288),注册资本10034.392万元,目前员工6…

嵌入式4-24

作业: 整理思维导图 定义一个矩形类Rec,包含私有属性length,width,有以下成员函数: void set_length(int l); //设置长度 void set_width(int w); //设置宽度 int get_length(); //获取长度 int get_width(); //获取宽…

Julia教程(一):变量

1、变量 在 Julia 中,变量是与值关联(或绑定)的名称。当想要存储一个值(例如,经过一些数学运算后获得的值)以供以后使用时,它非常有用。例如: # 定义一个变量x,并赋值为…

力扣:82. 删除排序链表中的重复元素 II(Java)

目录 题目描述:输入:输出:代码实现: 题目描述: 给定一个已排序的链表的头 head , 删除原始链表中所有重复数字的节点,只留下不同的数字 。返回 已排序的链表 。 输入: head [1,2,3…

AXI4---低功耗接口

在电子系统设计中,"low-power interface"(低功耗接口)是指专为减少能耗而设计的硬件接口。这类接口在不需要牺牲性能的情况下,通过各种技术降低功耗,对于移动设备、嵌入式系统和其他电池供电的应用来说尤其重…

为什么要使用gamma校正?

为什么要使用gamma校正? 人眼直接观察实物相机拍摄、存储、输出到显示器上,人眼再观察该物体1. 拍摄2. 存储3. 显示 总结:在计算机时代早期,为了抵消当时主流的RTC显示器的非线性特征,拍摄图片存储过程中需要gamma校正…