如何解决使用 Java 中的 JSON 密钥访问 GCS 并得到 Method 抛出“com.google.cloud.storage.StorageException”异常？

我试图用 Java 将文件上传到 GCS。

以下是我创建 Storage 对象的方式：

StorageOptions.Builder storageOptions = StorageOptions.newBuilder().setProjectId(AppProperties.get(GCS_PROJECT_ID));

GoogleCredentials credentials = GoogleCredentials.fromStream(new FileInputStream(keyFilePath)).createScoped(Lists.newArrayList("https://www.googleapis.com/auth/cloud-platform"));

Storage storage = storageOptions.setCredentials(credentials).build().getService();

当我尝试执行 storage.create(blobInfo,Files.readAllBytes(Paths.get(dataFolder + "/" + fileName))); 时，出现以下错误：

com.google.cloud.storage.StorageException: Unexpected error refreshing access token
    at com.google.cloud.storage.spi.v1.HttpStorageRpc.translate(HttpStorageRpc.java:233)
    at com.google.cloud.storage.spi.v1.HttpStorageRpc.create(HttpStorageRpc.java:314)
    at com.google.cloud.storage.StorageImpl$3.call(StorageImpl.java:221)
    at com.google.cloud.storage.StorageImpl$3.call(StorageImpl.java:218)
    at com.google.api.gax.retrying.DirectretryingExecutor.submit(DirectretryingExecutor.java:105)
    at com.google.cloud.RetryHelper.run(RetryHelper.java:76)
    at com.google.cloud.RetryHelper.runWithRetries(RetryHelper.java:50)
    at com.google.cloud.storage.StorageImpl.internalCreate(StorageImpl.java:217)
    at com.google.cloud.storage.StorageImpl.create(StorageImpl.java:171)

Caused by: java.io.IOException: Unexpected error refreshing access token
    at com.google.auth.oauth2.OAuth2Credentials.unwrapDirectFuture(OAuth2Credentials.java:309)
    at com.google.auth.oauth2.OAuth2Credentials.getRequestMetadata(OAuth2Credentials.java:156)
    at com.google.auth.oauth2.ServiceAccountCredentials.getRequestMetadata(ServiceAccountCredentials.java:962)
    at com.google.auth.http.HttpCredentialsAdapter.initialize(HttpCredentialsAdapter.java:96)
    at com.google.cloud.http.HttpTransportOptions$1.initialize(HttpTransportOptions.java:159)
    at com.google.cloud.http.CensusHttpModule$CensusHttpRequestinitializer.initialize(CensusHttpModule.java:109)
    at com.google.api.client.http.HttpRequestFactory.buildrequest(HttpRequestFactory.java:91)
    at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:521)
    at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:455)
    at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:565)
    at com.google.cloud.storage.spi.v1.HttpStorageRpc.create(HttpStorageRpc.java:311)
    ... 14 more
Caused by: java.lang.NoSuchMethodError: com.google.common.io.ByteStreams.exhaust(Ljava/io/InputStream;)J
    at com.google.api.client.http.ConsumingInputStream.close(ConsumingInputStream.java:40)
    at java.util.zip.InflaterInputStream.close(InflaterInputStream.java:227)
    at java.util.zip.GZIPInputStream.close(GZIPInputStream.java:136)
    at sun.nio.cs.StreamDecoder.implClose(StreamDecoder.java:378)
    at sun.nio.cs.StreamDecoder.close(StreamDecoder.java:193)
    at java.io.InputStreamReader.close(InputStreamReader.java:199)
    at com.google.gson.stream.JsonReader.close(JsonReader.java:1224)
    at com.google.api.client.json.gson.GsonParser.close(GsonParser.java:53)
    at com.google.api.client.json.JsonParser.parse(JsonParser.java:363)
    at com.google.api.client.json.JsonParser.parse(JsonParser.java:335)
    at com.google.api.client.json.JsonObjectParser.parseAndClose(JsonObjectParser.java:79)
    at com.google.api.client.json.JsonObjectParser.parseAndClose(JsonObjectParser.java:73)
    at com.google.api.client.http.HttpResponse.parseAs(HttpResponse.java:456)
    at com.google.auth.oauth2.ServiceAccountCredentials.refreshAccesstoken(ServiceAccountCredentials.java:618)
    at com.google.auth.oauth2.OAuth2Credentials$1.call(OAuth2Credentials.java:243)
    at com.google.auth.oauth2.OAuth2Credentials$1.call(OAuth2Credentials.java:240)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:457)
    at com.google.auth.oauth2.OAuth2Credentials$AsyncRefreshResult.executeIfNew(OAuth2Credentials.java:567)
    at com.google.auth.oauth2.OAuth2Credentials.asyncFetch(OAuth2Credentials.java:206)
    ... 24 more

我验证了密钥文件是有效的，因为相同的密钥文件在气流中完美地工作以在 Python 中上传文件

pom 如下：

<dependencies>
        <dependency>
            <groupId>com.google.cloud</groupId>
            <artifactId>google-cloud</artifactId>
            <version>0.8.0</version>
        </dependency>

        <dependency>
            <groupId>com.google.collections</groupId>
            <artifactId>google-collections</artifactId>
            <version>1.0</version>
        </dependency>

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>30.1.1-jre</version>
        </dependency>

        <dependency>
            <groupId>com.google.cloud</groupId>
            <artifactId>google-cloud-storage</artifactId>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.google.cloud</groupId>
                <artifactId>libraries-bom</artifactId>
                <version>20.8.0</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

这只发生在 Intellij 中。我尝试在命令行上直接执行 jar，它对我有用

有人可以帮忙吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

<iframe src="https://storage.googleapis.com/vrview/2.0/embed?image=https://terrafrost.sfo2.digitaloceanspaces.com/tannehill/DJI_0896.JPG&is_stereo=true">
</iframe>

@Override
public void onFailure(DataStorageException dse) {

    String message = String.format("Got %s - %s while synchronizing dataset...",dse.getClass().getSimpleName(),dse.getMessage());
    Log.e(TAG,message,dse);

    super.onFailure(dse);
}

@Override
public void onFailure(final DataStorageException dse) {
    callingActivity.runOnUiThread(new Runnable() {
        @Override
        public void run() {
            dialog.dismiss();
            Log.e("Sync","Failed: " + dse);
            Toast.makeText(callingActivity,"Sync Failed due to\n" + dse.getMessage(),Toast.LENGTH_LONG)
                .show();
            dse.printstacktrace();
        }
    });
}

@Override
public void onFailure(final DataStorageException dse) {
    callingActivity.runOnUiThread(new Runnable() {
        @Override
        public void run() {
            dialog.dismiss();
            Log.e("Sync",Toast.LENGTH_LONG)
                .show();
            dse.printstacktrace();
        }
    });
}

hej
san

textfile = open("/file_path/test.txt",'r')
times = textfile.read().splitlines()
textfile.close()
print(times)

['hej','san']

from google.cloud import storage

client = storage.Client()

bucket = client.get_bucket('test_bucket')

blob = bucket.get_blob('temp_files_folder/test.txt')

print(blob.download_as_string)

<bound method Blob.download_as_string of <Blob: test_bucket,temp_files_folder/test.txt>>