问题标签 [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.
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 的安全连接
我已经在我的代表中运行了这个命令:
知道该怎么做吗?
sql - 如何在 Apache nifi 中执行 Begin-End Transact SQL 语句?
我正在尝试在使用 Apache Nifi 中的 Execute SQL 处理器之间使用 Begin - End 和 Cursor 执行 SQL 语句。但这会引发一个错误,告诉“无法执行 SQL 选择查询”。如何在 nifi 中执行事务 SQL 语句?哪种处理器最适合这个?
下面是我试图执行的 SQL 代码片段,
sql - 如何在 nifi 中替换 ExecteSQL 处理器查询中的 json 值?
我正在尝试替换从 nifi 中的另一个处理器获取的查询中的值,我该如何实现这一点或最好的方法是什么?处理器详细信息如下,
- 执行 SQL 处理器 ->
SELECT Rno FROM sampleDB WHERE operation = 1;
- SplitAvro 处理器
- 将 Avro 转换为 Json -> 在这里我得到以下 JSON
{'Rno':'121'}
- 执行 SQL 处理器 ->
DELETE FROM NewDB WHERE Rno = X
(此处 X 应替换为从前一个处理器接收到的 Rno,即“121”)
如何实现第 4 步除上述处理器外还应使用哪些处理器?
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”附近的语法不正确。
无法弄清楚错误在哪里,或者有什么更好的方法来实现这一点。
docker - NiFi Registry docker 文件未更新“远程克隆存储库”属性
NiFi Registry 版本 0.8.0 未在其 docker 文件中更新远程克隆存储库。我不确定这是一个错误还是有其他选择。有什么建议么?
这是脚本文件的链接,GitHub NiFi Registry Shell Script
报告的问题链接NiFi Registry JIRA
nginx - 带有(客户端)SSL/TLS 和基本身份验证的 nginx 代理后面的 NiFi 注册表
我有一个 Nifi 和一个 Nifi-Registry 都在 docker + docker-compose 之上的 Nginx 代理后面的两个不同 AWS EC2 实例上运行。在 HTTP 上运行良好,但不安全。
现在我试图让事情更安全一点:
- 使用自签名 SSL/TLS 证书保护 Nifi-Registry
- 从浏览器访问 Nifi-Registry 时添加基本身份验证。
- 使用客户端-服务器证书确保客户端-服务器(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 处理器组上启动版本控制时,我收到以下错误:
看起来 Nifi 未能使用其客户端证书在 Nifi-Registry 实例上对 Nginx 进行身份验证,因此 Nginx 回复 401。
我试过几次按照说明进行操作,但我不确定我哪里出错了。
这是我的 Nifi-Registry 实例 docker-compose.yaml 配置和 Nginx 反向代理设置:
Nginx default.conf 与作者博客文章中的相同:
在 Nifi 实例上,如博客文章中所述,我已将CA 签名的文件client_keystore.p12
和client_trustorestore.p12
所需文件复制到 nifi docker 容器中nifi.properties
我想我错过了一些东西,或者客户端-服务器证书不匹配......希望有人能指出这一点。
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.
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)