How to Get a Job in Google Dataflow

Java Client Library

package com.wordpress.simplesassim.gcp;

import static java.lang.System.out;

import com.google.dataflow.v1beta3.GetJobRequest;
import com.google.dataflow.v1beta3.Job;
import com.google.dataflow.v1beta3.JobsV1Beta3Client;

public class GcpSample {

  public static void main(String... args) throws Exception {
    JobsV1Beta3Client client = JobsV1Beta3Client.create();

    GetJobRequest req = GetJobRequest.newBuilder().setProjectId("sampleproject").setJobId("samplejobid").build(); // location defaults to "us-central1"

    Job job = client.getJob(req);

    out.println(job.getName());

    client.close();
  }

}

Python Client Library

from google.cloud import dataflow_v1beta3

client = dataflow_v1beta3.JobsV1Beta3Client()

req = dataflow_v1beta3.GetJobRequest(project_id = 'sampleproject', job_id = 'samplejobid') # location defaults to 'us-central1'

job = client.get_job(req)

print(job)

CLI

1) Setup the CLI:

gcloud init

2) Run the following command:

gcloud dataflow jobs show samplejobid # location defaults to 'us-central1'

Terraform Provider

N/A.

Published by:

Fernando Ribeiro

Experienced tech executive with a 24-year track record in enterprise computing. Leading AWS's professional services application modernization division in Brazil. He's held diverse roles including management, solutions architecture, sales consultancy, and full-stack development at major players like Oracle, Red Hat, and IBM. Fernando also contributes to open source and writes about emerging technologies. The views expressed here are his own and do not necessarily reflect the views of AWS.

Categories SoftwareTags , , , , , , , Leave a comment

Leave a comment

This site uses Akismet to reduce spam. Learn how your comment data is processed.