使用 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 集合的主要内容,如果未能解决你的问题,请参考以下文章
JAVA - Apache BEAM- GCP:GroupByKey 与 Direct Runner 一起工作正常,但与 Dataflow runner 一起失败
使用 Dataflow 在 BigQuery 表之间进行流式更新