能否在同一Beam任务中写入两个不同的Firestore数据库？

是的，你完全可以在单个Beam管道中同时写入默认Firestore数据库和另一个自定义数据库，不需要局限于全局管道选项绑定的单一数据库。核心思路是为每个数据库创建独立的Firestore客户端配置，而不是依赖管道初始化时的全局设置。

具体实现步骤： #

• 对于默认数据库：直接使用无额外配置的FirestoreIO.write()，它会自动读取管道选项中的默认项目配置连接默认数据库。
• 对于自定义数据库：通过FirestoreOptions手动指定数据库ID和项目信息，再基于该配置构建专属的写入变换。

示例代码片段（Java为例）：

// 写入默认Firestore数据库
PCollection<YourDataModel> defaultDbData = ...;
defaultDbData.apply("Write to Default DB", FirestoreIO.write()
    .withProjectId("your-project-id")
    .to("collection-path-in-default-db"));

// 写入自定义Firestore数据库
FirestoreOptions customDbOptions = FirestoreOptions.newBuilder()
    .setProjectId("your-project-id")
    .setDatabaseId("your-custom-db-id")
    .build();

PCollection<YourDataModel> customDbData = ...;
customDbData.apply("Write to Custom DB", FirestoreIO.write()
    .withFirestoreOptions(customDbOptions)
    .to("collection-path-in-custom-db"));

关键注意点： #

• 确保两个写入变换使用独立的配置，避免全局选项覆盖问题。
• 若使用Python等其他语言，逻辑类似：通过显式指定数据库ID参数区分不同的数据库写入客户端。
• 权限层面，需保证Beam作业使用的服务账号同时拥有两个数据库的写入权限。

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