我們可以使用數據流重命名雲存儲文件嗎

Question

我正在嘗試使用數據流程序重命名雲存儲文件。有可能這樣做嗎？如果是，那麼如何。

Answer 1

雖然Apache的梁SDK不包含現成的重命名文件PTransform，沒有什麼阻止你做自己 - 管道可以包含任意代碼DoFn的，你既可以使用標準的Google Cloud Storage Java APIs，或更方便地使用Beam的FileSystems API。例如：

class RenameFn extends DoFn<KV<String, String>, Void> { 
    @ProcessElement 
    public void process(ProcessContext c) { 
    ResourceId src = FileSystems.matchNewResource(c.element().getKey()); 
    ResourceId dest = FileSystems.matchNewResource(c.element().getValue()); 
    FileSystems.rename(Arrays.asList(src), Arrays.asList(dest)); 
    } 
}