java-如何使用服务帐户凭据将文件上传到Google Team Drive中的文件夹？ - 堆栈溢出

-
java-如何使用服务帐户凭据将文件上传到Google Team Drive中的文件夹？ - 堆栈溢出

2

我正在尝试使用Google Drive Java API v3为我们的应用程序实施一项新服务，该服务负责将文件上传到Google Team Drive中的特定文件夹。我使用公司专门为此项目创建的服务帐户，并且还从Google Developer Console生成了一个包含私钥的JSON文件。我还使用电子邮件xxxxx@xxxx.iam.gserviceaccount.com将文件夹共享到服务帐户，并将Content Manager的权限授予了共享的Team Drive。此外，由于某些原因，未授予该服务帐户整个G Suite范围的权限。


我要在这里实现的目标是：我想使用服务帐户的生成的私钥构建并返回授权的Google Drive客户服务，因此能够发送将文件上传到Google Team Drive中的文件夹的请求。

我目前使用的是：

  • IntelliJ IDEA IntelliJ IDEA 2018.1.7（最终版）
  • 春季靴2
  • Java 10.0.1

问题是什么：
我无法成功返回授权的Google云端硬盘客户端服务，并且根本没有发送上传文件的请求。更令人困惑的是，没有引发异常。但是，将成功返回带有访问令牌和到期时间的凭据。

我已经阅读/找到的内容：
使用OAuth2.0从服务器到服务器的应用程序：https : //developers.google.com/identity/protocols/OAuth2ServiceAccount

创建对Drive API的简单请求的Java快速入门：https： //developers.google.com/drive/api/v3/quickstart/java

云端硬盘API的JavaDoc参考：https : //developers.google.com/resources/api-libraries/documentation/drive/v3/java/latest/

如何使用服务帐户凭据将文件上传到Google驱动器：如何使用服务帐户凭据 将文件上传到Google驱动器

如何使用带有Google Drive .NET API v3的服务帐户访问Team Drive： 如何使用带有Google Drive .NET API v3的服务帐户访问Team Drive

验证使用Java的Google驱动器API客户端库上传驱动器中的文件验证使用 Java的Google驱动器API客户端库 上传驱动器中的文件

我已经尝试过的：

  • 使用GoogleCredential-class返回凭据（该类似乎已弃用：https： //googleapis.dev/java/google-api-client/latest/ ）
  • 通过查看Github项目和教程来查找不推荐使用的类的替代品
  • 更新并检查pom.xml中所有缺少的依赖项
  • 检查了共享Team Drive的设置，以确保已与服务帐户共享
  • 添加了日志以确保问题确实是我上面描述的
  • 尝试使用Java快速入门创建对Drive API教程的简单请求（但是，事实证明这并不完全适合我们项目的需求）

ContractStateUpdateService.java的相关部分：

File fileMetadata = new File();
fileMetadata.setName(fileTitle);
// setting the id of folder to which the file must be inserted to
fileMetadata.setParents(Collections.singletonList("dumbFolderId"));
fileMetadata.setMimeType("application/pdf");

byte[] pdfBytes = Base64.getDecoder().decode(base64File.getBytes(StandardCharsets.UTF_8));
InputStream inputStream = new ByteArrayInputStream(pdfBytes);

// decoding base64 to PDF and its contents to a byte array without saving the file on the file system
InputStreamContent mediaContent = new InputStreamContent("application/pdf", inputStream);

logger.info("Starting to send the request to drive api");
File file = DriveUtils.getDriveService().files().create(fileMetadata, mediaContent).execute();
logger.info("Succesfully uploaded file: " + file.getDriveId());

DriveUtils.java：

public class DriveUtils {

    private static final String APPLICATION_NAME = "Google Drive Service";

    // setting the Drive scope since it is essential to access Team Drive
    private static List<String> SCOPES = Collections.singletonList(DriveScopes.DRIVE);

    // private key is stored at the root of the project for now
    private static String PRIVATE_KEY_PATH = "/path/to/private_key.json";
    private static final Logger logger = LoggerFactory.getLogger(DriveUtils.class);

    // build and return an authorized drive client service
    public static Drive getDriveService() throws IOException, GeneralSecurityException {
        final NetHttpTransport HTTP_TRANSPORT = GoogleNetHttpTransport.newTrustedTransport();
        GoogleCredentials credentials;

        try (FileInputStream inputStream = new FileInputStream(PRIVATE_KEY_PATH)){
            credentials = ServiceAccountCredentials.fromStream(inputStream).createScoped(SCOPES);
            credentials.refreshIfExpired();
            AccessToken token = credentials.getAccessToken();
            logger.info("credentials: " + token.getTokenValue());
        } catch (FileNotFoundException ex) {
            logger.error("File not found: {}", PRIVATE_KEY_PATH);
            throw new FileNotFoundException("File not found: " + ex.getMessage());
        }

        logger.info("Instantiating client next");
        // Instantiating a client: this is where the client should be built but nothing happens... no exceptions!
        Drive service = new Drive.Builder(HTTP_TRANSPORT, JSON_FACTORY, (HttpRequestInitializer) credentials)
                .setApplicationName(APPLICATION_NAME)
                .build();
        // this log should appear immediately after the client has been instantiated but still nothing happens
        logger.info("Client instantiated");

        return service;
    }

}

pom.xml：

<!-- https://mvnrepository.com/artifact/com.google.api-client/google-api-client -->
        <dependency>
            <groupId>com.google.api-client</groupId>
            <artifactId>google-api-client</artifactId>
            <version>1.29.2</version>
        </dependency>

        <dependency>
            <groupId>com.google.apis</groupId>
            <artifactId>google-api-services-drive</artifactId>
            <version>v3-rev165-1.25.0</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.google.auth/google-auth-library-oauth2-http -->
        <dependency>
            <groupId>com.google.auth</groupId>
            <artifactId>google-auth-library-oauth2-http</artifactId>
            <version>0.16.1</version>
        </dependency>


        <!-- https://mvnrepository.com/artifact/org.springframework.security.oauth/spring-security-oauth2 -->
        <dependency>
            <groupId>org.springframework.security.oauth</groupId>
            <artifactId>spring-security-oauth2</artifactId>
            <version>2.3.6.RELEASE</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.google.oauth-client/google-oauth-client-jetty -->
        <dependency>
            <groupId>com.google.oauth-client</groupId>
            <artifactId>google-oauth-client-jetty</artifactId>
            <version>1.29.0</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.google.code.gson/gson -->
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.5</version>
        </dependency>

我确定我在这里遗漏了一些东西，我事先为我的英语道歉。任何帮助将不胜感激。

6月13日上午8:16 问
性急的
214 4枚青铜徽章
  • 1个
    h！看到您的详细问题后，我感到受宠若惊。天哪！这么多细节。因此，赞成。 –  surajs1n 6月13日8:21
  • 我在使用它们时发生了一件这样的事情TranslationClient，那是因为我的系统时间未同步，并且令牌甚至在使用前就过期了。尽管这只是我的经验，但这也可能是您的原因。 –  Navjot Singh 6月14日13:24
0

感谢您的评论，这里的建议很有帮助，值得研究。但是，我将在此处介绍的解决方案无法直接回答有关我的代码如何或为什么不产生任何错误消息的问题。因此，现在，这是我针对该问题的解决方法：

  1. 启用云端硬盘API。在阅读了有关从服务帐户向Drive API发出请求的文章和文档的大部分内容之后，很明显，如果我们没有从Google API Console中启用Drive API，我的代码将无法正常工作。
  2. 将三个依赖项的版本降级到1.23.0。

pom.xml：

 <dependency>
    <groupId>com.google.api-client</groupId>
    <artifactId>google-api-client</artifactId>
    <version>1.23.0</version>
 </dependency>
 <dependency>
    <groupId>com.google.apis</groupId>
    <artifactId>google-api-services-drive</artifactId>
    <version>v3-rev110-1.23.0</version>
 </dependency>
 <dependency>
    <groupId>com.google.oauth-client</groupId>
    <artifactId>google-oauth-client-jetty</artifactId>
    <version>1.23.0</version>
 </dependency>
  1. 将属性的值设置setSupportsTeamDrive为true。没有该属性，我们将根本无法将文件保存到Team Drive中的共享文件夹中。

ContractStateUpdateService.java：

File fileMetadata = new File();
fileMetadata.setName(fileTitle);

// setting the id of folder to which the file must be inserted to
fileMetadata.setParents(Collections.singletonList("dumbTeamDriveId"));
fileMetadata.setMimeType("application/pdf");

// decoding base64 to PDF and its contents to a byte array without saving the file on the file system
byte[] pdfBytes = Base64.getDecoder().decode(base64File.getBytes(StandardCharsets.UTF_8);
InputStream inputStream = new ByteArrayInputStream(pdfBytes);
InputStreamContent mediaContent = new InputStreamContent("application/pdf", inputStream);

try {
  // upload updated agreement as a PDF file to the Team Drive folder
  DriveUtils.getDriveService().files().create(fileMetadata, mediaContent)
                            .setSupportsTeamDrives(true) // remember to set this property to true!
                            .execute();
} catch (IOException ex) {
  logger.error("Exception: {}", ex.getMessage());
  throw new IOException("Exception: " + ex.getMessage());
} catch (GeneralSecurityException ex) {
  logger.error("Exception: {}", ex.getMessage());
  throw new GeneralSecurityException("Exception: " + ex.getMessage());
}
  1. 拆分方法以使逻辑更清晰。

更新了DriveUtils-class中的代码：

// create and return credential
private static Credential getCredentials() throws IOException {
    GoogleCredential credential = GoogleCredential.fromStream(new FileInputStream(PRIVATE_KEY_PATH))
                .createScoped(SCOPES);

    return credential;
}

// build and return an authorized drive client service
public static Drive getDriveService() throws IOException, GeneralSecurityException {
    final NetHttpTransport HTTP_TRANSPORT = GoogleNetHttpTransport.newTrustedTransport();

    // Instantiating a client
    Drive service = new Drive.Builder(HTTP_TRANSPORT, JSON_FACTORY, getCredentials())
                .setApplicationName(APPLICATION_NAME)
                .build();

    return service;
}
七月5在20:01 回答
性急的
214 4枚青铜徽章

你的答案

    注册或登录

    使用Google注册
    使用Facebook注册
    使用电子邮件和密码注册

    以访客身份发布

    名称
    电子邮件

    必需，但从未显示

    点击“发布答案”，即表示您同意我们的服务条款，隐私政策和Cookie政策

    不是您要找的答案？浏览标记为 的其他问题， 或者询问您自己的问题。



    Tags:
    November 20, 2019 at 09:41AM
    Open in Evernote

    评论

    发表评论

    此博客中的热门博文

    Telegram MTProto Proxy 介绍说明 – 开源代码|技术|教程资源|网络资源|首页不显示 – 如有乐享

    -
    图片
    Telegram MTProto Proxy 介绍说明 A – A +  我是小马甲~  2018年6月2日  1  16484 次浏览  开源代码 | 技术 | 教程资源 | 网络资源 | 首页不显示  MTProto Proxy | MTProxy | Telegram | Telegram代理 | 科学无忧 | 科学无忧上网 文章目录 酸酸(乳)代理 SOCKS5 Proxy 如何设置 MTProto Proxy 支持的客户端 开源地址 快速参考 注册您的代理 自定义配置 推荐频道 注意到昨天的一个新闻：苹果在全球范围内阻止Telegram消息应用的更新！ Telegram 的路不好走呀！前一段儿时间博主的TG群，有人发送不可描述的图片。导致这个群直接被ban！目前看只是针对IOS平台ban了这个群。其他平台暂时没事儿！博主建议大家，好好的聊天！别乱搞！ 目前国内已经屏蔽了 Telegram APP相关服务，想使用 TG 必须挂代理才行！下面介绍一些路子方法。 酸酸(乳)代理 这个就不多说了。 SOCKS5 Proxy 比较老的一种代理方式。抗感染能力比较差一点！ 下面是网友分享的2个！ 1 2 server = r43271237 . teletype . live & port = 1080 & user = telegram & pass = telegram server = r432 . tgproxy . run & port = 1080 & user = telegram & pass = telegram 如何设置 1 2 3 4 5 6 7 8 • Telegram Android ( Settings ➔ Data and Storage ➔ Proxy Settings ) • Telegram X iOS Alpha ( Settings ➔ Data and Storage ➔ Proxy ) • Telegram Des...
    阅读全文

    监控FRPS端口并自动重启进程linux脚本_FRP教程_电脑博士

    -
    图片
    监控FRPS端口并自动重启进程linux脚本_FRP教程_电脑博士 RSS订阅 专注X86/ARM架构技术 电脑博士 menu 首 页 导航 内网穿透 关于站长 博客交流QQ群693563350 赞助本站 你现在的位置： 网站首页 / FRP教程 / 正文内容 监控FRPS端口并自动重启进程linux脚本 44 0 FRP教程 | 2019年10月10日 监控服务进程监听端口,当服务器监听端口停止时,自动重启服务进程。 如下监听frps服务器的7000端口,当7000端口不处于监听状态时或异常退出时,则自动重启frps进程服务,并记录当前时间保存到日志文件。 Bash #!/bin/bash #author: bos #www: www.diannaobos.com #Monitor FrpServer script #check root user if [ $( id -u ) != "0" ] ; then echo " Not the root user! Try using sudo Command ! " exit 1 fi netstat -nl | grep -q 7000 if [ $? -ne 1 ] ; then exit ; fi echo $( date +%T%n%F ) " Restart Frp Services " >> frps.log #restart frps /root/frp/frps -c /root/frp/frps.ini & 将上面代码创建为Monitor_FrpServer.sh 另外定时执行该脚本,来维护进程服务的正常运行。 例如每1分钟自动执行一次，可以在周期计划中配置如下: * * * * * sh /root/Monitor_FrpServer.sh 󰄼 赞 0 赏 󰄯 分享 上一篇：根据CPU负载及内存使用率自动重启FRPS服务进程linux脚本 猜你喜欢 08-06 ubuntu16.04系...
    阅读全文

    进阶Spring Boot(二)---Tomcat与Undertow 吞吐量对比 - 简书

    -
    图片
    进阶Spring Boot(二)---Tomcat与Undertow 吞吐量对比 - 简书 进阶Spring Boot(二)---Tomcat与Undertow 吞吐量对比 翼云先森 1 2018.10.19 10:45:30 字数 777 阅读 17,543 测试工具：Jmeter        Apache JMeter是Apache组织开发的基于Java的压力测试工具。用于对软件做压力测试，它最初被设计用于Web应用测试，但后来扩展到其他测试领域。 它可以用于测试静态和动态资源，例如静态文件、Java 小服务程序 、CGI 脚本、Java 对象、数据库、FTP 服务器， 等等。JMeter 可以用于对服务器、网络或对象模拟巨大的负载，来自不同压力类别下测试它们的强度和分析整体性能。另外，JMeter能够对应用程序做功能/ 回归测试 ，通过创建带有断言的脚本来验证你的程序返回了你期望的结果。为了最大限度的灵活性，JMeter允许 使用正则表达式 创建断言。        Apache jmeter 可以用于对静态的和动态的资源（文件，Servlet，Perl脚本，java 对象，数据库和查询， FTP服务器 等等）的性能进行测试。它可以用于对服务器、网络或对象模拟繁重的负载来测试它们的强度或分析不同压力类型下的整体性能。你可以使用它做性能的图形分析或在大并发 负载测试 你的服务器/脚本/对象。 测试Tomcat ,因为Spring Boot默认服务器是Tomcat，所以可以直接测试 第一步，打开Jmeter 配置线程组，请求次数10000次 image.png 在线程组上添加http请求配置 image.png 配置聚合报告，查看运行吞吐量 image.png 测试三次后，取平均值，测试结果跟电脑配置有关，不同电脑结果不一样，我们只是在同一配置同一时间对比吞吐量 image.png 测试Undertow        默认情况下，Spring Boot 使用 Tomcat 来作为内嵌的 Servlet 容器，可以将 Web 服务器切...
    阅读全文