使用shell讀取文字檔案傳送到kafka

#!/bin/sh

## 引數定義
dt=`date +"
%y%m%d
" -d "
-1 days"`
outpath=/***x_log_$.txt 
brokerlist=192.168.1
.100:9092,192.168.1.101:9092,192.168.1.102:9092
echo
$dt $outpath $brokerlist
## 查詢hive表，輸出檔案到指定路徑
hive -e "
select
name,age from test" > $
## 判斷檔案大小，如果大於0，則載入檔案，寫入kafka
## 注意 結尾的 | > out.txt要加上，否則會出現很多奇怪的大於號filesize=`du -b $ | awk''
`if [ $filesize -gt 0 ] then
cat $ | ./kafka_2.11-1.0.0/bin/kafka-console-producer.sh --broker-list $ --sync --topic test1 |>out.txt

fi

讀取文字檔案

void ctestdlg onreadinfo cfile filewrite1 testwrite1.txt cfile modecreate cfile modewrite cfile filewrite2 testwrite2.txt cfile modecreate cfile modew...

使用fscanf讀取文字檔案

fscanf為讀取文字檔案的乙個c api，其特點是可格式化讀取檔案內容。1 file pf fopen c hello.txt r 2if null pf 3return 4 5char cstr 256 6fscanf pf,s cstr 7fclose pf fscanf使用空格，tab，回車...

讀取文字檔案內容

讀取文字檔案內容 param filepathandname 帶有完整絕對路徑的檔名 param encoding 文字檔案開啟的編碼方式 return 返回文字檔案的內容 public string readtxt string filepathandname,string encoding th...