问题标签 [apache-nifi-registry]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
324 浏览

apache-nifi - Nifi-Registry - 与 git 集成

我正在使用 Apache NiFi-Registry 并希望将其与 git 集成。因此,我有一个注册表 docker 容器,其中包含 git rep 所在的主机目录的卷。我使用 https 克隆了代表,并在容器中使用了不安全的 nifi-registry 实例。providers.xml 文件如下所示:

提交工作正常,但没有推送:

错误 [GitFlowMetaData 推送线程] oanrpflow.git.GitFlowMetaData 由于 org.eclipse.jgit.api.errors.TransportException 无法将提交推送到源:https://myuser@xxx/path/to/rep.git:安全连接到https://myuser@xxx/path/to/rep.git 由于 SSL 问题无法建立 org.eclipse.jgit.api.errors.TransportException: https://myuser@xxx/path/to/rep.git : 由于 SSL 问题,无法建立到 https://myuser@xxx/path/to/rep.git 的安全连接

我已经在我的代表中运行了这个命令:

知道该怎么做吗?

0 投票
1 回答
96 浏览

sql - 如何在 Apache nifi 中执行 Begin-End Transact SQL 语句?

我正在尝试在使用 Apache Nifi 中的 Execute SQL 处理器之间使用 Begin - End 和 Cursor 执行 SQL 语句。但这会引发一个错误,告诉“无法执行 SQL 选择查询”。如何在 nifi 中执行事务 SQL 语句?哪种处理器最适合这个?

下面是我试图执行的 SQL 代码片段,

0 投票
0 回答
97 浏览

sql - 如何在 nifi 中替换 ExecteSQL 处理器查询中的 json 值?

我正在尝试替换从 nifi 中的另一个处理器获取的查询中的值,我该如何实现这一点或最好的方法是什么?处理器详细信息如下,

  1. 执行 SQL 处理器 ->SELECT Rno FROM sampleDB WHERE operation = 1;
  2. SplitAvro 处理器
  3. 将 Avro 转换为 Json -> 在这里我得到以下 JSON{'Rno':'121'}
  4. 执行 SQL 处理器 -> DELETE FROM NewDB WHERE Rno = X(此处 X 应替换为从前一个处理器接收到的 Rno,即“121”)

如何实现第 4 步除上述处理器外还应使用哪些处理器?

0 投票
2 回答
76 浏览

sql - 如何在 nifi 中执行 SQL 处理器中执行“NOT IN”子句

我正在尝试使用 Apache nifi 中的“ExecuteSQL”处理器执行以下查询。

这里${rno}作为流文件属性获得。

执行时出现以下错误:

ExecuteSQL[id=01781107-63a4-1204-8110-6b19db3d5ffc] 无法执行 SQL 选择查询 INSERT INTO LimsOnCloud VALUES (1, 'CTG123', 'ITM123', '123', '5') WHERE 1 NOT IN (SELECT rno来自样本数据库);对于 StandardFlowFileRecord[uuid=93db20b2-5f9f-4521-ac42-11239abb94c2,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1615281573937-132, container=default, section=132], offset=168254, length=152],offset=0 ,name=098a8ad2-0dc9-4564-a242-8b4855b619b2,size=152] 由于关键字“WHERE”附近的语法不正确。;路由失败:com.microsoft.sqlserver.jdbc.SQLServerException:关键字“WHERE”附近的语法不正确。

无法弄清楚错误在哪里,或者有什么更好的方法来实现这一点。

0 投票
1 回答
149 浏览

apache-nifi - NiFi Registry 0.8.0 无法加载缓存项错误

我下载了 NiFi Registry 0.8.0 版本并运行了run-nifi-registry.bat文件,但它给出了以下错误,有什么建议吗?所有设置均为默认值

JDK:14
操作系统:Windows 10

在此处输入图像描述

0 投票
0 回答
66 浏览

docker - NiFi Registry docker 文件未更新“远程克隆存储库”属性

NiFi Registry 版本 0.8.0 未在其 docker 文件中更新远程克隆存储库。我不确定这是一个错误还是有其他选择。有什么建议么?

这是脚本文件的链接,GitHub NiFi Registry Shell Script

报告的问题链接NiFi Registry JIRA

0 投票
0 回答
356 浏览

nginx - 带有(客户端)SSL/TLS 和基本身份验证的 nginx 代理后面的 NiFi 注册表

我有一个 Nifi 和一个 Nifi-Registry 都在 docker + docker-compose 之上的 Nginx 代理后面的两个不同 AWS EC2 实例上运行。在 HTTP 上运行良好,但不安全。

现在我试图让事情更安全一点:

  1. 使用自签名 SSL/TLS 证书保护 Nifi-Registry
  2. 从浏览器访问 Nifi-Registry 时添加基本身份验证。
  3. 使用客户端-服务器证书确保客户端-服务器(nifi <-> nifi-registry)之间的通信安全。

我遇到了 Michal Klempa 的这篇https://michalklempa.com/2019/04/nifi-registry-nginx-proxy-tls-basic-auth/ 博客文章。按照上面链接中描述的方法,我在访问 https://[MY-NIFI-REG-HOST].com:18433/nifi-registry 时设法获得了基本身份验证的 Nifi-Registry 请求。下一步是让 Nifi 绕过客户端-服务器证书身份验证。

我已将 https://[MY-NIFI-REG-HOST].com:18433 作为“注册表客户端”添加到 Nifi 控制器设置。但是,当我尝试在其中一个 Nifi 处理器组上启动版本控制时,我收到以下错误:

身份验证 401 错误

看起来 Nifi 未能使用其客户端证书在 Nifi-Registry 实例上对 Nginx 进行身份验证,因此 Nginx 回复 401。

我试过几次按照说明进行操作,但我不确定我哪里出错了。

这是我的 Nifi-Registry 实例 docker-compose.yaml 配置和 Nginx 反向代理设置:

Nginx default.conf 与作者博客文章中的相同:

在 Nifi 实例上,如博客文章中所述,我已将CA 签名的文件client_keystore.p12client_trustorestore.p12所需文件复制到 nifi docker 容器中nifi.properties

我想我错过了一些东西,或者客户端-服务器证书不匹配......希望有人能指出这一点。

0 投票
1 回答
306 浏览

apache-nifi - 如何将错误从处理器传递到 NiFi 中的 PutEmail 处理器

在下图中,我们可以清楚地看到 Conversion_Batching 处理器中的错误。如何将此错误传输到 PutEmail,以便电子邮件收件人可以清楚地了解错误。

在此处输入图像描述

以下是PutEmail配置:

在此处输入图像描述

但是${error}没有收到前一个处理器的错误,我收到一封空邮件,主题设置正确。

我怎样才能做到这一点?

0 投票
0 回答
104 浏览

azure - Is there a way to upload files to Azure file share using apache nifi?

I am trying to upload files to Azure file share present in azure storage account. Is there any combination of processors in nifi that I can use to upload files. Unfortunately there is no direct processor for file share available like blob storage.

0 投票
0 回答
462 浏览

oracle - 如何在 Nifi 中更改时区?

我们正在连接 Oracle 数据库。从 ExecuteSQL 处理器查询日期时,日期列时区将更改为 UTC。我们怎样才能避免这种情况?即使我在控制器服务属性中添加了 oracle.jdbc.timezoneAsRegion=false ,但它仍然不起作用。我们不想编辑 bootstrap.conf 来更改时区。有没有办法改变 Nifi 的时区?

此外,如果我在 DB 中的日期列值具有2021-06-20 01:00:00,则在 nifi 中读取时,该值将更改为2021-06-19 19:30:00 ,我们可以看到 5:30 小时的差异。如果我通过 java 代码运行它,同样的事情,我得到一个确切的日期值,就像在 DB 中一样。我的系统中运行 Nifi 的时区是时区:亚洲/加尔各答(IST,+0530)