使用 Dataflow 和 Java 删除 Firestore 集合

Posted

技术标签:

【中文标题】使用 Dataflow 和 Java 删除 Firestore 集合【英文标题】:Delete Firestore Collection Using Dataflow & Java 【发布时间】:2020-07-29 16:29:18 【问题描述】:

我在 Java 中有一个函数,它从 firestore 集合中读取数据并以固定的批量大小删除它们。 我想从数据流中执行这个,但是当我在 .apply 中添加这个时,我得到了编译错误: “Pipeline 类型中的 apply(String, PTransform) 方法不适用于参数 (String, void)”

apply里面怎么调用这样的函数

【问题讨论】:

【参考方案1】:

您能否提供代码示例以及详细说明您的错误的堆栈跟踪?这将有助于更好地可视化您可能想要实现的目标。

此documentation 提供有关删除 Cloud Firestore 中的整个集合或子集合的详细信息。如果您使用较大的集合,您可以选择以较小的批次删除数据以避免内存不足错误。 code snippet 稍微简化了一些,但提供了批量删除集合的方法。

【讨论】:

以上是关于使用 Dataflow 和 Java 删除 Firestore 集合的主要内容,如果未能解决你的问题,请参考以下文章

使用 Dataflow Java 代码加入嵌套结构表

从 Dataflow 作业连接到 Cloud SQL

JAVA - Apache BEAM- GCP:GroupByKey 与 Direct Runner 一起工作正常,但与 Dataflow runner 一起失败

使用 Dataflow 在 BigQuery 表之间进行流式更新

Google Dataflow - 如果写入本地服务器,如何在 java 中指定 TextIO?

本地 Pubsub 模拟器不适用于 Dataflow