如何使用Apache光束库[org.apache.beam.sdk.io.*]获取/添加GCS文件用户定义的元数据
如何使用Apache光束库[org.apache.beam.sdk.io.*]获取/添加GCS文件用户定义的元数据
提问于 2019-06-25 09:20:53
我正在设置一个数据流管道，其中的一个操作是获取/添加GCS文件的metadataUser提供的元数据。
在一个独立的java应用程序中，我使用下面的方法来获取元数据，这些元数据来自StorageObject类，但在Apache Beam库中找不到类似的方法/api。任何点子都会很有帮助。
//Below code is from StorageObject.java
com.google.api.services.storage.model.StorageObject
//.....
public java.util.Map<String, java.lang.String> getMetadata() {
return metadata;
}回答 1
Stack Overflow用户
回答已采纳
发布于 2019-07-02 13:50:53
我使用以下代码从GCS获取元数据，它在DataFlow管道中工作良好。
import com.google.cloud.storage.{BlobId, BlobInfo, Storage, StorageOptions}
val storage: Storage = StorageOptions.getDefaultInstance.getService
val blobId: BlobId = BlobId.of("bucket", "filename")
val srcMap: Map[String, String] = storage.get(blobId).getMetadata页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/56745649
复制相关文章
相似问题
腾讯云开发者
