ssl - 如何使用 InvokeHTTP 或 ExecuteStreamCommand 处理器在 Apache NiFi 中执行 curl 请求？

Question

所以我在向 Hive 发送 curl 请求时遇到了困难。我想获取我创建的 json 流文件并将其作为命令发送到 Hive，但是当我尝试配置 InvokeHTTP 处理器时，我不断收到错误消息。这里的引用是我目前的工作流程。替换Text->Update Attributes->InvokeHTTP->Put processor

我主要尝试让 InvokeHTTP 处理器工作。我的配置是:1.HTTP方法:POST2.远程网址:${ https://hive-prod-1.sample_text/alert }3.SSL上下文服务:StandardSSLContext服务4.代理类型:https-内容类型:application/json

然后我添加了一个属性5.curl: curl-XPOST-H"Authorization: Bearer xWJbexxxxxxxx -H "Content-Type: application/json'

我不确定是我的配置不正确还是存在其他问题。

当我尝试使用/配置 ExecuteStreamCommand 时:1.命令参数:curl-XPOST-H"Authorization xxxxx -H "Content-type: application/json2.命令路径:application/json参数定界符:;

同样，我不确定这些处理器的配置是否正确，或者它是否与证书有关。当我运行它时，我还会收到错误消息“java.lang.illegalstateexception: trustmanagerfactory = is not initialized”。

Answer 1

这听起来好像您没有成功/完全配置SSLContextService，这是连接到使用 TLS 的服务时 InvokeHTTP 所必需的。您的 Hive 实例受 TLS 保护，因此您需要获取 Hive 实例的公共(public)证书(您可以通过浏览器、使用 openssl s_client 等)，将公共(public)证书加载到Java keystore (JKS) 将 truststore 文件格式化为 trustedCertEntry，然后将 SSLContextService 指向该信任库文件。有关详细信息，请查看 Tomas Zezula's article on NiFi SSL configuration 的第一部分.