在 NiFi 处理器“InvokeHTTP”中,您在哪里编写 POST 请求的正文?

2024-02-26

在发布有关 Apache NiFi InvokeHTTP 的问题之前,我已经浏览了所有其他问题及其答案,但我仍然不确定我应该拥有的最佳流程。我的情况如下:

1)从 Apache Kafka,我获取原始元数据。

2)使用EvaluateJSONPath我得到了我想要的属性。

3) 使用 RouteOnAttribute,我根据上面第 2 步中获得的属性值创建了 3 条路由。

4) 现在,根据属性值,我想决定是否应该进行 GET、POST 或删除。

5)我的问题是在哪里/如何设置POST消息?获取消息?删除邮件正文?

6) 我可以在 InvokeHTTP 提供的配置部分中设置 URL。但消息体我不知道那个属性是什么?或者它在流文件中使用 ReplaceText?

我在某处读到,在将 Restful POST HTTP 请求转移到 InvokeHTTP 之前,您必须有另一个处理器,然后才能更改流文件的内容。

Ref: 配置来自 Nifi 的 HTTP POST 请求 https://stackoverflow.com/questions/39116067/configuring-http-post-request-from-nifi

请帮忙。谢谢。 问候, 耶什旺特


添加 Bryan 所解释的内容,POST 将使用 FlowFile 内容作为消息正文,因此,如果您有一些其他数据想要擦除/转换为某种内容,然后作为消息正文发送,您可以利用以下处理器:

  • ExtractText从现有的 FlowFile 内容中读取数据
  • ReplaceText擦除 FlowFile 的现有内容并将其替换为不同的内容

要设置 REST 调用的标头,InvokeHTTP有财产Attributes to Sendproperty,它采用正则表达式,该正则表达式将扫描传入的 FlowFiles 的属性,并且匹配的属性将被获取并作为 HTTP 标头发送。

要向现有 FlowFile 添加新属性,您可以使用UpdateAttribute

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在 NiFi 处理器“InvokeHTTP”中,您在哪里编写 POST 请求的正文? 的相关文章

随机推荐

  • 插入数据库 php 后表情符号显示为问号

    我使用utf8mb4作为编码 character set connection和character set database已设置为utf8mb4 我的网页的字符集设置为utf8 我使用了 PDO 当我打开数据库连接时 我使用 utf8mb
  • 仅使用 javascript 生成并保存/下载文件 [关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi
  • 冒号运算符在 MATLAB 中如何工作?

    如中所述山姆 罗伯茨的回答 https stackoverflow com a 26297279 7328782 and gnovice 的另一个答案 https stackoverflow com a 5779438 7328782 MA
  • 从函数返回范围

    我试图让 VBA 中的子函数调用另一个函数 该函数返回一个范围并设置为一个变量 当我尝试运行 GetInputs 方法时出现语法错误 Function GetDataRange str As String As Range This pro
  • 使用 shell 脚本启动远程 (SSH) Java 应用程序将不会返回本地提示符

    我见过类似的问题 所有解决的问题都已解决 不适用 我在远程计算机中有一个启动 Java 应用程序的 bash 脚本 相关行是 usr bin env bash java cp full path to my jar com whatever
  • Flood Fill算法导致StackOverFlowError

    我正在使用 Java 编写一个简单的绘图应用程序 我正在尝试使用洪水填充算法的递归实现作为我的 桶填充 工具 然而 这always给我一个StackOverFlowError 无论我使用 桶填充工具 的区域有多小 编辑 更改了代码以使其更加
  • 以编程方式将文件检入 TFS 的结果超出预期

    因此 我有一个 NET 应用程序 它会生成一系列文件 将它们输出到本地目录 然后确定是否需要更新现有文件或将新文件添加到 TFS Team Foundation Server 项目中 我的本地计算机上有一个工作区 并且有 10 个不同的工作
  • 注释随情节表达而变化?

    假设我想制作一个像这样的子图 其中每个方面都有自己的 y 尺度 import plotly express as px fig px scatter px data iris x sepal length y sepal width fac
  • UnicodeEncodeError:“ascii”编解码器无法对位置 20 中的字符 u'\xa0' 进行编码:序号不在范围内(128)

    我在处理从不同网页 在不同站点上 获取的文本中的 unicode 字符时遇到问题 我正在使用美丽汤 问题是错误并不总是可重现的 它有时可以处理某些页面 有时 它会通过抛出一个UnicodeEncodeError 我已经尝试了几乎所有我能想到
  • 设备或资源在容器中从头开始忙于 alpine,但在 ubuntu 上却不忙

    我编辑了问题 但我的问题表现在高山容器中 我现在从头开始在容器中遇到同样的问题 这是同一个问题 但范围更窄一些 正如标题所描述的 我在 Ubuntu 容器中有一个工作可执行文件 我用它来构建我的应用程序 但是一旦我将其复制到 Alpine
  • 如何使用 Rails、Cucumber 和 Capybara 测试 Dropzone.js 上传?

    我有一个使用 Cucumber 和 Capybara 进行测试的 Rails 项目 我有一个使用 Dropzone js 的文件上传页面 我的上传使用对话框或拖放效果很好 测试是另一回事 我的表单中有以下字段
  • 有没有用R写的遗传编程代码[关闭]

    Closed 这个问题正在寻求书籍 工具 软件库等的推荐 不满足堆栈溢出指南 help closed questions 目前不接受答案 我对进化算法很感兴趣 我已经用 R 测试了遗传算法 但有人尝试过遗传编程吗 你知道吗 某个地方是否有用
  • 为什么 C# 不提供类似于 C++ 的常量性?

    C 中的引用与 C 中的引用非常相似 只不过它们是垃圾收集的 为什么 C 编译器支持以下内容如此困难 成员函数标记const 对标记的数据类型 字符串除外 的引用const 通过其中仅const可以调用成员函数吗 我相信如果 C 支持这一点
  • 从 Python 运行 m 文件

    pymat 似乎不适用于当前版本的 matlab 所以我想知道是否还有另一个等效的版本 我还没有找到 理想的要点是从 python 2 6 运行一个 m 文件 像 scipy 这样的替代方案不适合 因为我认为它们不能运行 m 文件中的所有内
  • 如何在 Saxon 中使用 XPath 3.1?

    我当前使用 XPath 3 1 语法 但由于某种原因 Saxon 输出错误 To use XPath 3 1 syntax you must configure the XPath parser to handle it 我该怎么做呢 非常
  • LINQ 选择间隔 X 分钟的记录

    我有一个简单的表格来记录输入日期 我想选择相隔 X 分钟的记录 IMAGE LOCATION IMAGE DATE 2227 jpg 08 03 2014 22 27 47 2228 jpg 08 03 2014 22 28 48 2229
  • 如何在我的小程序中使用 JXMapViewer?

    我想编写一个必须使用缩放 平移工具渲染地图图像的小程序 我发现 JXMapViewer 可以帮助我 我该如何使用它 我在哪里可以找到相关文档 帮助我编写一个小程序 请求我的图像服务器提供要渲染的图块 图像服务器怎么样 帮助我 JXMapVi
  • Android 模拟器错误:std::bad_alloc

    我正在使用 Eclipse Juno 和 Android 模拟器 SDK Tools 21 1 并且多次遇到此错误 嗯 6 小时内出现两到三次 2013 03 22 11 41 19 Emulator terminate called af
  • Apache proxypass 缓存的 IP 地址

    我使用 Apache Web 服务器 2 4 通过 proxypass 指令将传入的 HTTP 请求代理到我们的后端服务器 我还通过 Apache 传递来自后端服务器的传出请求 再次使用 proxypass 例如 lt Location o
  • 在 NiFi 处理器“InvokeHTTP”中,您在哪里编写 POST 请求的正文?

    在发布有关 Apache NiFi InvokeHTTP 的问题之前 我已经浏览了所有其他问题及其答案 但我仍然不确定我应该拥有的最佳流程 我的情况如下 1 从 Apache Kafka 我获取原始元数据 2 使用EvaluateJSONP