apache-nifi - Nifi在HDFS路径上为前一天合并的json文件移动文件
问题描述
我需要将前一天处理并合并的 json 文件移动到新的 hdfs 路径中。要求是递归搜索未处理的文件并移动待处理的未处理文件。
路径 1 -> /data/nifi/working/2019/10/source_2019_10_15.json --- 每日处理的文件合并在此路径下,并每天添加。路径 2 -> /data/nifi/incoming/ - 代码应该搜索文件夹是否不存在,然后创建和移动文件,如果文件夹已经存在则移动文件。
目前,我正在使用 nifi flow -- ListHDFS->MoveHDFS 但无法实现。
需要帮助如何实现这一点。
感谢您的帮助。
解决方案
当前流程运行良好。
listhdfs->fethchdfs->updateattribute->puthdfs
在 listhdfs 中,设置消耗前的最小文件年龄等待时间。这将允许进程递归搜索文件,并使用 updateattribute 重新创建文件夹并将文件处理到 /data/nifi/incoming/。
推荐阅读
- django - Django意外地只存储密码哈希,而不是算法参数
- javascript - 收到错误 this.state.datas.map is not a function
- nativescript - Nativescript RadListView 使用页脚滚动到底部
- dynamic - nextJS 动态路由页面结构
- python - 如何在 Flask 中导入路由?
- javascript - 通过 JS 脚本和 Google Sheets API 抓取图表作为图像?
- python - scipy.optimize.minimize 给出部分不正确的结果
- java - android studio如何保存关闭前显示的数据?
- python - 按组用下一个可用值替换 Python 中的空值
- bash - 如何在 bash 脚本中的 CSV 的下一列中添加文本