使用Dataflow和Java删除Firestore集合

import com.google.api.core.ApiFuture;
import com.google.cloud.firestore.CollectionReference;
import com.google.cloud.firestore.DocumentReference;
import com.google.cloud.firestore.Firestore;
import com.google.cloud.firestore.FirestoreOptions;
import com.google.cloud.firestore.QueryDocumentSnapshot;
import com.google.cloud.firestore.QuerySnapshot;
import com.google.cloud.firestore.WriteResult;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.TextIO;
import org.apache.beam.sdk.options.PipelineOptionsFactory;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.ParDo;

import java.util.concurrent.ExecutionException;

public class DeleteFirestoreCollection {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 创建Firestore实例
        FirestoreOptions firestoreOptions = FirestoreOptions.getDefaultInstance().toBuilder()
                .setProjectId("your-project-id")
                .build();
        Firestore firestore = firestoreOptions.getService();

        // 获取要删除的集合的引用
        CollectionReference collectionRef = firestore.collection("your-collection");

        // 获取集合中的所有文档的引用
        ApiFuture<QuerySnapshot> future = collectionRef.get();
        QuerySnapshot querySnapshot = future.get();
        for (QueryDocumentSnapshot document : querySnapshot) {
            // 删除每个文档
            DocumentReference documentRef = collectionRef.document(document.getId());
            ApiFuture<WriteResult> deleteFuture = documentRef.delete();
            deleteFuture.get();
        }

        // 使用Dataflow创建一个任务，将结果写入到输出文件
        PipelineOptionsFactory.register(MyOptions.class);
        MyOptions options = PipelineOptionsFactory.fromArgs(args).withValidation().as(MyOptions.class);
        Pipeline pipeline = Pipeline.create(options);
        pipeline.apply("Create", TextIO.write().to("output.txt"));
        pipeline.run().waitUntilFinish();
    }

    public interface MyOptions extends org.apache.beam.sdk.options.PipelineOptions {
    }
}