磚

當我試著設置“pathGlobFilter”自動裝卸機工作,它似乎過濾掉一切。桶/目錄設置就像's3a: / / my_bucket / level_1_dir / level_2_dir / < some_name > /一/二/ < the_files_i_want_to_load > '所以我想要的是可以 …

我有一個函數是使用“cloudFiles”來源從s3流文件內容。其配置是這樣的:' ' '流= (spark.readStream.format .option (“cloudFiles (“cloudFiles”)。格式”、“文本”).option (“cloudFiles.schemaLo……

我得到這個失敗原因在一個相當簡單的流媒體工作。我在一個筆記本運行工作。筆記本依賴於python模塊,我同步與dbx的DBFS。在筆記本一般來說,可用的模塊,即。“進口mymo…