2017-09-19 46 views
0

我在尝试使用下面的函数来创建一个谷歌的云斗:项目参数创建谷歌云桶(Java API)时,未找到

def createBucket(bucketName: String, credentials: String): Bucket = { 

    val credentialStream = new ByteArrayInputStream(
     credentials.getBytes(StandardCharsets.UTF_8.name())) 
    val storage = StorageOptions.newBuilder 
     .setCredentials(ServiceAccountCredentials.fromStream(credentialStream)) 
     .build() 
     .getService() 
    storage.create(BucketInfo.newBuilder(bucketName).build()) 
    } 

我读的凭证流是一个标准的谷歌云凭据JSON并包含项目ID。不过,我收到了一条错误java.lang.NullPointerException: Required parameter project must be specified如下图所示:

play.api.UnexpectedException: Unexpected exception[StorageException: java.lang.NullPointerException: Required parameter project must be specified.] 
     at play.api.http.HttpErrorHandlerExceptions$.throwableToUsefulException(HttpErrorHandler.scala:276) 
     at play.api.http.DefaultHttpErrorHandler.onServerError(HttpErrorHandler.scala:206) 
     at play.api.GlobalSettings$class.onError(GlobalSettings.scala:160) 
     at play.api.DefaultGlobal$.onError(GlobalSettings.scala:188) 
     at play.api.http.GlobalSettingsHttpErrorHandler.onServerError(HttpErrorHandler.scala:98) 
     at play.core.server.netty.PlayRequestHandler$$anonfun$2$$anonfun$apply$1.applyOrElse(PlayRequestHandler.scala:100) 
     at play.core.server.netty.PlayRequestHandler$$anonfun$2$$anonfun$apply$1.applyOrElse(PlayRequestHandler.scala:99) 
     at scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scala:346) 
     at scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scala:345) 
     at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) 
Caused by: com.google.cloud.storage.StorageException: java.lang.NullPointerException: Required parameter project must be specified. 
     at com.google.cloud.storage.StorageException.translateAndThrow(StorageException.java:71) 
     at com.google.cloud.storage.StorageImpl.create(StorageImpl.java:114) 
     at models.services.CloudServiceImpl.createBucket(CloudServiceImpl.scala:728) 

任何想法,这可能是为什么?我试图按照这里列出的API指南:https://cloud.google.com/storage/docs/creating-buckets#storage-create-bucket-java

回答

0

所以,事实证明,从证书JSON创建存储对象并不会将其分配给JSON引用的项目。必须手动设置:

val storage = StorageOptions.newBuilder 
    .setCredentials(ServiceAccountCredentials.fromStream(credentialStream)) 
    .setProjectId(projectId) 
    .build 
    .getService