2016-10-28 58 views
0

我想使用snakebite檢查文件是否存在於hdfs目錄中,如果不存在,就創建它。我下面就touchzhere的文檔,並使用它像這樣:Snakebite HDFS touchz無法正常工作

def createFile(client): 
    if client.test("/user/test/sample.txt", exists=True): 
     print "file exists" 
    else: 
     print "file not exist, create file" 
     print client.touchz(["/user/test/sample.txt"]) 

client = Client(remote_host, 8020, use_trash=False)   
createFile(client) 

但是,當我去檢查,我沒有看到sample.txt的在remote_host:/user/test/ 但我看到,當我用hadoop fs -touchz remote_host:/user/test/sample.txt

文件

如何使用蛇咬的touchz

回答

0

snakebite的touchz會產生一個發生器,除非您重複這些值,否則不會執行任何操作。

因此,您必須迭代返回值touchz或調用list()就可以了。