各位超级用户大家下午好。
最近我读到了很多有用的答案,它们帮助我解决了之前的疑问。我决定加入社区并发布我的第一个问题。之前已经调查过是否有答案,但找不到解决我的问题的方法。
我是 Apache NiFi 的新手。我需要设置一个非常简单的流程,即从 Twitter 获取一些特定的推文,从中提取消息并写入本地文件夹。
如果我没记错的话,流程很简单,只需放置 3 个处理器:GetTwitter --> EvaluateJsonPath --> PutFile。
看起来 EvaluateJsonPath 没有执行从 json 中提取推文消息的工作。在其属性选项卡中,我设置了以下内容:
- 目的地:流文件属性;
- 返回类型:自动检测
- 路径未找到行为:忽略
- 空值表示:空字符串
然后我添加了如下属性:
- twitter.msg:$.text
整个流程正常进行,推文被捕获并通过 EvaluateJsonPath,然后到达 PutFile,它将所有即将到来的推文(几乎)实时写入我电脑中的特定文件夹。
但是,我看到文件夹中写入的文件是具有推文所有属性的 json。我得到的结果与将 GetTwitter 处理器直接连接到 PutFile 时得到的结果相同!
有人知道我做错了什么吗? 也许有更好的解决方案来实现它?
记住我的目标:我只想从所有推文中挑选消息并将它们存储在我的电脑中。附加问题:是否可以将这些消息存储为 .txt 格式?
非常感谢大家阅读我的问题并发布答案(如果有的话):)
谨致问候,路易斯·帕斯托