如何借助Beam仅通过Job ID以编程方式取消GCP Dataflow作业

如果你只有Dataflow作业的Job ID，没有保存PipelineResult实例，可以通过以下两种方式取消作业：

方式一：使用Java代码调用Dataflow API #

需要引入Google Cloud Dataflow的客户端依赖，通过Job ID定位作业并发起取消请求：

import com.google.cloud.dataflow.v1beta3.JobsV1Beta3Client;
import com.google.dataflow.v1beta3.Job;
import com.google.dataflow.v1beta3.JobName;
import com.google.dataflow.v1beta3.UpdateJobRequest;
import com.google.protobuf.FieldMask;

public class DataflowJobCanceller {
    public static void main(String[] args) {
        String projectId = "你的项目ID";
        String region = "作业所在区域（如us-central1）";
        String jobId = "要取消的作业ID";

        try (JobsV1Beta3Client client = JobsV1Beta3Client.create()) {
            // 构建作业的唯一标识
            JobName jobName = JobName.of(projectId, region, jobId);

            // 构建更新请求，将作业状态设置为取消
            Job job = Job.newBuilder()
                    .setState(Job.State.JOB_STATE_CANCELLED)
                    .build();

            FieldMask updateMask = FieldMask.newBuilder()
                    .addPaths("state")
                    .build();

            UpdateJobRequest request = UpdateJobRequest.newBuilder()
                    .setJobName(jobName.toString())
                    .setJob(job)
                    .setUpdateMask(updateMask)
                    .build();

            // 执行取消操作
            client.updateJob(request);
            System.out.println("作业 " + jobId + " 已成功取消");
        } catch (Exception e) {
            System.err.println("取消作业时出错：" + e.getMessage());
            e.printStackTrace();
        }
    }
}

方式二：使用gcloud命令行工具 #

如果不需要代码实现，直接用gcloud命令即可快速取消作业：

gcloud dataflow jobs cancel <你的Job ID> --region=<作业所在区域>

需确保已配置好gcloud环境并授权对应项目的Dataflow权限。

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