首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >shell 读取文件行

shell 读取文件行

作者头像
大数据工程师-公子
发布2019-03-14 14:49:04
发布2019-03-14 14:49:04
1.8K00
举报
运行总次数:0

有道笔记-shell 读取文件行 最近通过Spark Streaming消费Kafka数据,消费的数据落到hdfs,一分钟一个小文件,昨天架构那边的同事告诉我要清理历史文件,但是目录太多,手动删比较慢,于是想到可以把文件目录都拿到,写入文本 path_to_clean.txt,通过shell循环读路径,并执行删除。

代码语言:javascript
代码运行次数:0
运行
复制
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-01-09
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-07-05
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-09-05
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-10-20
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-11-06
hdfs://nameservice1/user/hadoop/dw_realtime/dw_real_for_path_list/mb_pageinfo_hash2/date=2016-11-07
...

已下是代码。

方式一(我才采用的是这种)

代码语言:javascript
代码运行次数:0
运行
复制
#!/bin/bash

for line in `cat path_to_clean.txt`
do
   echo $line
   hadoop fs -rm -r $line
done

方式二

代码语言:javascript
代码运行次数:0
运行
复制
#!/bin/bash
while read line
do
    echo $line
done < path_to_clean.txt

方式三

代码语言:javascript
代码运行次数:0
运行
复制
#!/bin/bash
cat path_to_clean.txt | while read line
do
    echo $line
done
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2017年01月10日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 方式一(我才采用的是这种)
  • 方式二
  • 方式三
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档