咨询Ballerina连接Google Cloud Firestore的连接器及连接方法

目前Ballerina Central暂未提供官方的Google Cloud Firestore连接器，但可以通过以下两种方式实现连接：

方法一：调用Firestore REST API #

这种方式无需额外依赖Java SDK，直接通过Ballerina HTTP客户端与Firestore的REST API交互。

1. 获取OAuth2访问令牌 #

首先需要使用Google Cloud服务账号密钥生成访问令牌，用于API请求的身份验证：

import ballerina/oauth2;
import ballerina/http;

oauth2:ServiceAccountConfig serviceAccountConfig = {
    keyFile: "/path/to/your-service-account-key.json",
    scopes: ["https://www.googleapis.com/auth/datastore"]
};

oauth2:Client oauth2Client = check new oauth2:Client(serviceAccountConfig);
string accessToken = check oauth2Client->getToken();

2. 调用Firestore API执行操作 #

以获取指定文档为例，替换代码中的PROJECT_ID、COLLECTION_ID和DOCUMENT_ID为实际值：

http:Client firestoreClient = check new http:Client("https://firestore.googleapis.com/v1");

http:Request request = new;
request.headers.set("Authorization", string`Bearer ${accessToken}`);

// 获取单个文档
http:Response response = check firestoreClient->get("/projects/{PROJECT_ID}/databases/(default)/documents/{COLLECTION_ID}/{DOCUMENT_ID}");
json documentData = check response.getJsonPayload();

你可以参考Firestore REST API的官方定义，扩展实现创建、更新、查询等更多操作。

方法二：通过Java互操作使用Firestore SDK #

利用Ballerina的Java互操作能力，直接调用Google官方的Firestore Java SDK，这种方式能复用SDK的完整功能。

1. 添加Java依赖 #

在项目的Ballerina.toml文件中添加Firestore Java SDK依赖：

[[platform.java11.dependency]]
path = "com.google.cloud:google-cloud-firestore:3.15.0"

2. 编写互操作代码 #

以下是初始化客户端并获取文档的示例：

import ballerina/jballerina.java;
import ballerina/log;

public function main() returns error? {
    // 加载服务账号密钥文件
    java:Class fileClass = check java:getClass("java.io.File");
    java:Object fileObj = check java:newInstance(fileClass, "/path/to/your-service-account-key.json");

    // 初始化Firestore客户端
    java:Class firestoreOptionsClass = check java:getClass("com.google.cloud.firestore.FirestoreOptions");
    java:Object optionsBuilder = check java:invokeStaticMethod(firestoreOptionsClass, "newBuilder", ());
    java:Class googleCredentialsClass = check java:getClass("com.google.auth.oauth2.GoogleCredentials");
    java:Object credentials = check java:invokeStaticMethod(googleCredentialsClass, "fromStream", (
        check java:invokeStaticMethod(check java:getClass("java.io.FileInputStream"), "newInputStream", (fileObj))
    ));
    optionsBuilder = check java:invokeMethod(optionsBuilder, "setCredentials", (credentials));
    java:Object firestore = check java:invokeMethod(check java:invokeMethod(optionsBuilder, "build", ()), "getFirestore", ());

    // 获取指定文档
    java:Object docRef = check java:invokeMethod(firestore, "collection", ("users"));
    docRef = check java:invokeMethod(docRef, "document", ("user1"));
    java:Object snapshot = check java:invokeMethod(docRef, "get", ());
    
    if check java:invokeMethod(snapshot, "exists", ()) {
        json docData = check java:convertFromJava(check java:invokeMethod(snapshot, "getData", ()));
        log:printInfo("Document content: " + docData.toString());
    }
}

两种方式对比 #

• REST API方式：轻量、无Java依赖，但需要手动处理API请求/响应的序列化与反序列化，适合简单场景。
• Java互操作方式：能使用SDK的全部功能（如实时监听、复杂查询），但依赖Java环境，代码复杂度较高。

内容的提问来源于stack exchange，提问作者Sachintha Fernando