如何在Ballerina中无需手动生成令牌，认证并上传文件至GCS

完全可以通过Ballerina实现你需要的所有操作，而且官方提供了现成模块来简化认证流程，自动处理令牌的生成与刷新，无需手动操作。以下是两种实现方案：

方案一：使用官方GCS专用模块（推荐） #

Ballerina的googleapis.gcs模块内置了服务账号认证逻辑，会自动完成OAuth2令牌的获取和过期刷新，直接调用GCS API即可。

1. 添加依赖 #

在项目的Ballerina.toml中添加GCS模块依赖：

[dependencies]
googleapis.gcs = "1.x.x"  # 替换为最新稳定版本

2. 代码实现 #

import ballerina/io;
import googleapis.gcs;

public function main() returns error? {
    // 配置服务账号密钥路径
    gcs:ConnectionConfig gcsConfig = {
        auth: {
            credentials: {
                path: "/绝对路径/to/service-account.json"
            }
        }
    };

    // 初始化GCS客户端
    gcs:Client gcsClient = check new gcs:Client(gcsConfig);

    // 示例：上传本地文件到GCS存储桶
    io:File localFile = check io:open("/本地文件路径/to/upload-file.txt");
    check gcsClient->uploadObject("你的存储桶名称", "GCS中的文件名称.txt", localFile);

    io:println("文件上传完成");
}

方案二：手动实现OAuth2令牌获取（自定义场景） #

如果需要自定义HTTP请求流程，可以用Ballerina的oauth2模块手动实现服务账号的JWT认证，自动管理令牌生命周期。

代码实现 #

import ballerina/oauth2;
import ballerina/http;
import ballerina/io;

public function main() returns error? {
    // 读取服务账号JSON密钥
    json serviceAccount = check io:readJsonFile("/路径/to/service-account.json");

    // 配置JWT授权参数
    oauth2:JwtGrantConfig grantConfig = {
        tokenUrl: "https://oauth2.googleapis.com/token",
        clientId: serviceAccount.client_id.toString(),
        clientSecret: serviceAccount.private_key.toString(),
        issuer: serviceAccount.client_email.toString(),
        scope: "https://www.googleapis.com/auth/devstorage.read_write"
    };

    // 创建OAuth2客户端，自动处理令牌刷新
    oauth2:Client oauthClient = check new oauth2:Client(grantConfig);
    oauth2:AccessToken accessToken = check oauthClient->getToken();

    // 调用GCS上传API
    http:Client gcsApiClient = check new http:Client("https://storage.googleapis.com");
    io:File localFile = check io:open("/本地文件路径/to/upload-file.txt");
    
    http:Response uploadResp = check gcsApiClient->put(
        "/storage/v1/b/你的存储桶名称/o/GCS文件名称.txt?uploadType=media",
        localFile,
        headers = {
            "Authorization": `Bearer ${accessToken.accessToken}`
        }
    );

    if uploadResp.statusCode == 200 {
        io:println("上传成功");
    } else {
        io:println(`上传失败，状态码: ${uploadResp.statusCode}`);
    }
}

注意事项 #

• 服务账号JSON文件需要在Google Cloud IAM中配置GCS相关权限（比如Storage Object Admin角色），否则会出现权限不足错误。
• 方案一的googleapis.gcs模块已经封装了所有GCS操作细节，包括重试、令牌刷新，是生产环境的优先选择。
• 令牌的过期时间和刷新逻辑由模块自动处理，无需手动干预。

内容的提问来源于stack exchange，提问作者Virul Nirmala Wickremesinghe