ジョブとタスクを表示する

このドキュメントでは、Batch ジョブとタスクを表示する方法について説明します。

重要: ジョブが Batch から削除されると、そのジョブとタスクを表示することはできません。ジョブの削除はジョブの実行が終了してから 60 日後に自動的に行われます。詳細については、ジョブを削除するをご覧ください。

始める前に

1. Batch を以前に使用したことがない場合は、Batch を使ってみるを確認し、プロジェクトとユーザーの前提条件を完了して Batch を有効にします。

2. ジョブとタスクを表示するために必要な権限を取得するには、管理者にプロジェクトのバッチジョブ閲覧者（roles/batch.jobsViewer）またはバッチジョブ編集者（roles/batch.jobsEditor）の IAM ロールを付与するように依頼してください。ロールの付与については、プロジェクト、フォルダ、組織へのアクセスを管理するをご覧ください。

   必要な権限は、カスタムロールや他の事前定義ロールから取得することもできます。

ジョブを表示する

ジョブを表示するには、次のいずれかの方法を選択します。

• プロジェクト内のすべてのジョブを表示するには、ジョブのリストを表示します。

• 特定のジョブの構成の詳細をすべて表示するには、ジョブの詳細を表示します。

ジョブのリストを表示する

現在のプロジェクトのジョブのリストを表示するには、Google Cloud コンソール、gcloud CLI、Batch API、Go、Java、Node.js、Python、C++ を使用します。

コンソール

1. Google Cloud コンソールを使用して現在のプロジェクトのジョブのリストを表示するには、[ジョブリスト] ページに移動します。

   ジョブリストに移動する

   ジョブのリストは複数のページになる場合があります。次のページに進む必要がある場合は、画面下部の [次へ] をクリックします。

2. 省略可: ジョブのリストをフィルタする場合は、 [フィルタ] をクリックします。次に、プロパティと値を入力または選択します。

   たとえば、特定の状態のジョブのみを含むようにリストをフィルタするには、次のように入力します。

   Status:JOB_STATE
   

   JOB_STATE は、ジョブの状態（例: FAILED）に置き換えます。

   注: 一部のフィルタ オプション（たとえば、1 つ以上の特定の ラベルを持つジョブを表示する）は、Google Cloud コンソールではサポートされていません。他のフィルタ オプションについては、代わりに gcloud CLI または Batch API を使用してジョブを一覧表示します。

gcloud

すべてのジョブを表示

gcloud CLI を使用して現在のプロジェクト内のジョブのリストを表示するには、gcloud batch jobs list コマンドを使用します。

gcloud batch jobs list

フィルタされたジョブのリストを表示する

必要に応じて、1 つ以上のフラグを追加して、フィルタされたジョブのリストを表示できます。

• 特定のロケーションのジョブのみを表示するには、--location フラグを指定します。

• フィルタ式に基づいてジョブのみを表示するには、--filter フラグを指定します。

たとえば、次のコマンドを使用します。

gcloud batch jobs list \
    --location=LOCATION \
    --filter="FILTER_EXPRESSION"

以下を置き換えます。

• LOCATION: 1 つ以上のジョブが存在するロケーション。

• FILTER_EXPRESSION: 一覧表示するジョブを定義するフィルタ式。フィルタ式では、ゼロ個以上のブール演算子（AND、OR、NOT）で区切られた 1 つ以上のプロパティと値のペアを定義する必要があります。

  たとえば、次のフィルタ式をご覧ください。

  • ジョブの状態に基づいてフィルタする: 特定の状態のジョブのみを表示するには、次のフィルタ式を使用します。

    status.state="JOB_STATE"
    

    JOB_STATE は、ジョブの状態（例: FAILED）に置き換えます。

  • ラベルに基づいてフィルタする: プロジェクトで次のカスタムラベルが定義されているとします。

    • Cloud Billing レポートを表示するときに調査チームによって作成されたジョブとそのリソースを示すために、一部のジョブとそのリソースには research に設定された team ラベルがあります。

    • 時間に敏感なワークロードを示すために、一部のジョブには deadline ラベルがあり、さまざまな値に設定されています。

    • 開発チームが正常にテストした実行可能オブジェクトを示すために、一部の実行可能オブジェクトの tested ラベルは true に設定されています。

    次のフィルタ式を指定できます。

    (allocationPolicy.labels.team=research) AND ((labels.deadline:*) OR (runnables.labels.tested=true))
    

    このフィルタ式では、次の条件をすべて満たすジョブのみが一覧表示されます。

    • 研究チームからのジョブで、ジョブの割り当てポリシーの team ラベルが research に設定されているもの。

    • 次の条件の 1 つ以上を満たすジョブ。

      • 時間に敏感なジョブ。ジョブの deadline ラベルが任意の値に設定されているもの。

      • 正常にテストされた実行可能オブジェクトが 1 つ以上あるジョブ。true に設定された tested ラベルを持つ実行可能オブジェクトが 1 つ以上あるジョブです。

API

すべてのジョブを表示

Batch API を使用して、特定のロケーションの現在のプロジェクト内のジョブのリストを表示するには、jobs.list メソッドに GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs

以下を置き換えます。

• PROJECT_ID: 現在のプロジェクトのプロジェクト ID。

• LOCATION: ジョブが存在するロケーション。

フィルタされたジョブのリストを表示する

必要に応じて、filter クエリ パラメータを指定すると、フィルタ式に基づいてフィルタリングされたジョブのリストを表示できます。

たとえば、次の GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/example-project/locations/us-central1/jobs?filter=FILTER_EXPRESSION

FILTER_EXPRESSION は、URL エンコードを使用するフィルタ式に置き換えます。フィルタ式では、ゼロ個以上のブール演算子（AND、OR、NOT）で区切られた 1 つ以上のプロパティと値のペアを定義する必要があります。

たとえば、次のフィルタ式をご覧ください。

• ジョブの状態に基づいてフィルタする: 特定の状態のジョブのみを表示するには、次のフィルタ式を使用します。

  status.state="JOB_STATE"
  

  JOB_STATE は、ジョブの状態（例: FAILED）に置き換えます。

• ラベルに基づいてフィルタする: プロジェクトで次のカスタムラベルが定義されているとします。

  • Cloud Billing レポートを表示するときに調査チームによって作成されたジョブとそのリソースを示すために、一部のジョブとそのリソースには research に設定された team ラベルがあります。

  • 時間に敏感なワークロードを示すために、一部のジョブには deadline ラベルがあり、さまざまな値に設定されています。

  • 開発チームが正常にテストした実行可能オブジェクトを示すために、一部の実行可能オブジェクトの tested ラベルは true に設定されています。

  次のフィルタ式を指定できます。

  (allocationPolicy.labels.team%3Dresearch)%20AND%20((labels.deadline%3A*)%20OR%20(runnables.labels.tested%3Dtrue))
  

  注: URL エンコードされたフィルタ式は、次のデコードされたフィルタ式を表します。

    (allocationPolicy.labels.team=research) AND ((labels.deadline:*) OR (runnables.labels.tested=true))

  このフィルタ式では、次の条件をすべて満たすジョブのみが一覧表示されます。

  • 研究チームからのジョブで、ジョブの割り当てポリシーの team ラベルが research に設定されているもの。

  • 次の条件の 1 つ以上を満たすジョブ。

    • 時間に敏感なジョブ。ジョブの deadline ラベルが任意の値に設定されているもの。

    • 正常にテストされた実行可能オブジェクトが 1 つ以上あるジョブ。true に設定された tested ラベルを持つ実行可能オブジェクトが 1 つ以上あるジョブです。

Go

Go

詳細については、Batch Go API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import (
	"context"
	"fmt"
	"io"

	batch "cloud.google.com/go/batch/apiv1"
	"cloud.google.com/go/batch/apiv1/batchpb"
	"google.golang.org/api/iterator"
)

// Lists all jobs in the given project and region
func listJobs(w io.Writer, projectID, region string) error {
	// projectID := "your_project_id"
	// region := "us-central1"

	ctx := context.Background()
	batchClient, err := batch.NewClient(ctx)
	if err != nil {
		return fmt.Errorf("NewClient: %w", err)
	}
	defer batchClient.Close()

	req := &batchpb.ListJobsRequest{
		Parent: fmt.Sprintf("projects/%s/locations/%s", projectID, region),
	}

	var jobs []*batchpb.Job
	it := batchClient.ListJobs(ctx, req)

	for {
		job, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return fmt.Errorf("unable to list jobs: %w", err)
		}
		jobs = append(jobs, job)
	}

	fmt.Fprintf(w, "Jobs: %v\n", jobs)

	return nil
}

Java

Java

詳細については、Batch Java API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import com.google.cloud.batch.v1.BatchServiceClient;
import com.google.cloud.batch.v1.Job;
import java.io.IOException;

public class ListJobs {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    // Project ID or project number of the Cloud project you want to use.
    String projectId = "YOUR_PROJECT_ID";

    // Name of the region hosting the jobs.
    String region = "europe-central2";

    listJobs(projectId, region);
  }

  // Get a list of all jobs defined in given region.
  public static void listJobs(String projectId, String region) throws IOException {
    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `batchServiceClient.close()` method on the client to safely
    // clean up any remaining background resources.
    try (BatchServiceClient batchServiceClient = BatchServiceClient.create()) {

      // Construct the parent path of the job.
      String parent = String.format("projects/%s/locations/%s", projectId, region);

      for (Job job : batchServiceClient.listJobs(parent).iterateAll()) {
        System.out.println(job.getName());
      }
      System.out.println("Listed all batch jobs.");
    }
  }
}

Node.js

Node.js

詳細については、Batch Node.js API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

/**
 * TODO(developer): Uncomment and replace these variables before running the sample.
 */
// const projectId = 'YOUR_PROJECT_ID';
/**
 * The region that hosts the job.
 */
// const region = 'us-central-1';

// Imports the Batch library
const batchLib = require('@google-cloud/batch');

// Instantiates a client
const batchClient = new batchLib.v1.BatchServiceClient();

async function callListJobs() {
  // Construct request
  const request = {
    parent: `projects/${projectId}/locations/${region}`,
  };

  // Run request
  const iterable = await batchClient.listJobsAsync(request);
  for await (const response of iterable) {
    console.log(response);
  }
}

await callListJobs();

Python

Python

詳細については、Batch Python API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

from __future__ import annotations

from collections.abc import Iterable

from google.cloud import batch_v1


def list_jobs(project_id: str, region: str) -> Iterable[batch_v1.Job]:
    """
    Get a list of all jobs defined in given region.

    Args:
        project_id: project ID or project number of the Cloud project you want to use.
        region: name of the region hosting the jobs.

    Returns:
        An iterable collection of Job object.
    """
    client = batch_v1.BatchServiceClient()

    return client.list_jobs(parent=f"projects/{project_id}/locations/{region}")

C++

C++

詳細については、Batch C++ API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

#include "google/cloud/batch/v1/batch_client.h"

  [](std::string const& project_id, std::string const& location_id) {
    auto const parent = "projects/" + project_id + "/locations/" + location_id;
    // Initialize a client and issue the request.
    auto client = google::cloud::batch_v1::BatchServiceClient(
        google::cloud::batch_v1::MakeBatchServiceConnection());
    int i = 0;
    for (auto job : client.ListJobs(parent)) {
      if (!job) throw std::move(job).status();
      std::cout << "Job[" << i++ << "]  " << job->DebugString() << "\n";
    }
  }

ジョブの詳細を表示する

現在のプロジェクトのジョブの詳細は、Google Cloud コンソール、gcloud CLI、Batch API、Go、Java、Node.js、Python、C++ を使用して表示できます。

コンソール

重要: ジョブに関するすべての情報を表示するには、gcloud CLI、Batch API、またはクライアント ライブラリを使用します。

Google Cloud コンソールを使用して現在のプロジェクトのジョブの詳細を表示するには、次の手順に沿って操作します。

1. Google Cloud コンソールで、[ジョブリスト] ページに移動します。

   ジョブリストに移動する

2. [ジョブ名] 列で、ジョブの名前をクリックします。

   ジョブの詳細ページが開きます。

   デフォルトで [詳細] タブが開きます。詳細については、他のタブをクリックしてください。

gcloud

gcloud CLI を使用して現在のプロジェクトのジョブの詳細を表示するには、--location フラグを指定して gcloud batch jobs describe コマンドを使用します。

gcloud batch jobs describe JOB_NAME \
    --location=LOCATION

以下を置き換えます。

• JOB_NAME: 既存のジョブの名前。

• LOCATION: ジョブが存在するロケーション。

API

Batch API を使用して現在のプロジェクトのジョブの詳細を表示するには、jobs.get メソッドに GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs/JOB_NAME

以下を置き換えます。

• PROJECT_ID: 現在のプロジェクトのプロジェクト ID。

• LOCATION: ジョブが存在するロケーション。

• JOB_NAME: 既存のジョブの名前。

Go

Go

詳細については、Batch Go API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import (
	"context"
	"fmt"
	"io"

	batch "cloud.google.com/go/batch/apiv1"
	"cloud.google.com/go/batch/apiv1/batchpb"
)

// Retrieves the information about the specified job, most importantly its status
func getJob(w io.Writer, projectID, region, jobName string) (*batchpb.Job, error) {
	// projectID := "your_project_id"
	// region := "us-central1"
	// jobName := "some-job"

	ctx := context.Background()
	batchClient, err := batch.NewClient(ctx)
	if err != nil {
		return nil, fmt.Errorf("NewClient: %w", err)
	}
	defer batchClient.Close()

	req := &batchpb.GetJobRequest{
		Name: fmt.Sprintf("projects/%s/locations/%s/jobs/%s", projectID, region, jobName),
	}

	response, err := batchClient.GetJob(ctx, req)
	if err != nil {
		return nil, fmt.Errorf("unable to get job: %w", err)
	}

	fmt.Fprintf(w, "Job info: %v\n", response)

	return response, nil
}

Java

Java

詳細については、Batch Java API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import com.google.cloud.batch.v1.BatchServiceClient;
import com.google.cloud.batch.v1.Job;
import com.google.cloud.batch.v1.JobName;
import java.io.IOException;

public class GetJob {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    // Project ID or project number of the Cloud project you want to use.
    String projectId = "YOUR_PROJECT_ID";

    // Name of the region hosts the job.
    String region = "europe-central2";

    // The name of the job you want to retrieve information about.
    String jobName = "JOB_NAME";

    getJob(projectId, region, jobName);
  }

  // Retrieve information about a Batch Job.
  public static void getJob(String projectId, String region, String jobName) throws IOException {
    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `batchServiceClient.close()` method on the client to safely
    // clean up any remaining background resources.
    try (BatchServiceClient batchServiceClient = BatchServiceClient.create()) {

      Job job =
          batchServiceClient.getJob(
              JobName.newBuilder()
                  .setProject(projectId)
                  .setLocation(region)
                  .setJob(jobName)
                  .build());

      System.out.printf("Retrieved the job: %s ", job.getName());
    }
  }
}

Node.js

Node.js

詳細については、Batch Node.js API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

/**
 * TODO(developer): Uncomment and replace these variables before running the sample.
 */
// const projectId = 'YOUR_PROJECT_ID';
/**
 * The region that hosts the job.
 */
// const region = 'us-central-1';
/**
 * The name of the job you want to retrieve information about.
 */
// const jobName = 'YOUR_JOB_NAME';

// Imports the Batch library
const batchLib = require('@google-cloud/batch');

// Instantiates a client
const batchClient = new batchLib.v1.BatchServiceClient();

async function callGetJob() {
  // Construct request
  const request = {
    name: `projects/${projectId}/locations/${region}/jobs/${jobName}`,
  };

  // Run request
  const response = await batchClient.getJob(request);
  console.log(response);
}

await callGetJob();

Python

Python

詳細については、Batch Python API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

from google.cloud import batch_v1


def get_job(project_id: str, region: str, job_name: str) -> batch_v1.Job:
    """
    Retrieve information about a Batch Job.

    Args:
        project_id: project ID or project number of the Cloud project you want to use.
        region: name of the region hosts the job.
        job_name: the name of the job you want to retrieve information about.

    Returns:
        A Job object representing the specified job.
    """
    client = batch_v1.BatchServiceClient()

    return client.get_job(
        name=f"projects/{project_id}/locations/{region}/jobs/{job_name}"
    )

C++

C++

詳細については、Batch C++ API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

#include "google/cloud/batch/v1/batch_client.h"

  [](std::string const& project_id, std::string const& location_id,
     std::string const& job_id) {
    auto const name = "projects/" + project_id + "/locations/" + location_id +
                      "/jobs/" + job_id;
    // Initialize a client and issue the request.
    auto client = google::cloud::batch_v1::BatchServiceClient(
        google::cloud::batch_v1::MakeBatchServiceConnection());
    auto response = client.GetJob(name);
    if (!response) throw std::move(response).status();
    std::cout << "GetJob() succeeded with " << response->DebugString() << "\n";
  }

タスクを表示する

いずれかのジョブのタスクを表示するには、次のいずれかの方法を選択します。

• ジョブまたはジョブのタスクグループ内のすべてのタスクを表示するには、ジョブのタスクのリストを表示します。

• 特定のタスクの構成の詳細をすべて表示するには、タスクの詳細を表示します。

ジョブのタスクのリストを表示する

ジョブまたはジョブのタスクグループのタスクのリストを表示するには、Google Cloud コンソール、gcloud CLI、Batch API、Go、Java、Node.js、Python、C++ を使用します。

ジョブまたはジョブのタスクグループにあるタスクのリストをフィルタする場合（たとえば、正常に完了したタスクのみを一覧表示する場合）、gcloud CLI または Batch API を使用する必要があります。

コンソール

Google Cloud コンソールを使用してジョブのタスクの概要を表示するには、ジョブの詳細を表示して [ジョブの詳細] ページを開きます。次に、[タスクの詳細] セクションを確認します。

gcloud

gcloud CLI を使用してジョブのタスクグループ内のタスクのリストを表示するには、次のフラグを指定して gcloud batch tasks list コマンドを使用します。

gcloud batch tasks list \
    --job=JOB_NAME \
    --location=LOCATION

以下を置き換えます。

• JOB_NAME: 既存のジョブの名前。

• LOCATION: ジョブが存在するロケーション。

必要に応じて --filter フラグを追加すると、フィルタ式に基づいてジョブのタスクグループ内のフィルタされたタスクのリストを表示できます。

たとえば、次のコマンドを使用します。

gcloud batch tasks list \
    --job=example-job \
    --location=us-central1 \
    --filter="FILTER_EXPRESSION"

FILTER_EXPRESSION は、フィルタ式に置き換えます。

たとえば、次のフィルタ式を指定すると、実行中または実行が正常に完了したジョブのタスクグループ内のタスクのみを表示できます。

STATE=RUNNING OR STATE=SUCCEEDED

API

Batch API を使用してジョブのタスクグループのタスクのリストを表示するには、tasks.list メソッドに GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs/JOB_NAME/taskGroups/TASK_GROUP_NAME/tasks

以下を置き換えます。

• PROJECT_ID: 現在のプロジェクトのプロジェクト ID。

• LOCATION: ジョブが存在するロケーション。

• JOB_NAME: 既存のジョブの名前。

• TASK_GROUP_NAME: 詳細を表示するタスクグループの名前。値は group0 に設定する必要があります。

必要に応じて filter クエリ パラメータを指定すると、フィルタ式に基づいてジョブのタスクグループ内のフィルタリングされたタスクのリストを表示できます。

たとえば、次の GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/example-project/locations/us-central1/jobs/example-job/taskGroups/group0/tasks?filter=FILTER_EXPRESSION

FILTER_EXPRESSION は、URL エンコードを使用するフィルタ式に置き換えます。

たとえば、次のフィルタ式を指定すると、実行中または実行が正常に完了したジョブのタスクグループ内のタスクのみを表示できます。

STATE=RUNNING%20OR%20STATE=SUCCEEDED

URL エンコードされたフィルタ式は、次のデコードされたフィルタ式を表すことに留意してください。

STATE=RUNNING OR STATE=SUCCEEDED

Go

Go

詳細については、Batch Go API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import (
	"context"
	"fmt"
	"io"

	batch "cloud.google.com/go/batch/apiv1"
	"cloud.google.com/go/batch/apiv1/batchpb"
	"google.golang.org/api/iterator"
)

// Lists all tasks in the given project and region
func listTasks(w io.Writer, projectID, region, jobName, taskGroup string) error {
	// projectID := "your_project_id"
	// region := "us-central1"
	// jobName := "some-job"
	// taskGroup := "group0" // defaults to "group0" on job creation unless overridden

	ctx := context.Background()
	batchClient, err := batch.NewClient(ctx)
	if err != nil {
		return fmt.Errorf("NewClient: %w", err)
	}
	defer batchClient.Close()

	req := &batchpb.ListTasksRequest{
		Parent: fmt.Sprintf("projects/%s/locations/%s/jobs/%s/taskGroups/%s", projectID, region, jobName, taskGroup),
	}

	var tasks []*batchpb.Task
	it := batchClient.ListTasks(ctx, req)

	for {
		task, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return fmt.Errorf("unable to list tasks: %w", err)
		}
		tasks = append(tasks, task)
	}

	fmt.Fprintf(w, "Tasks: %v\n", tasks)

	return nil
}

Java

Java

詳細については、Batch Java API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import com.google.cloud.batch.v1.BatchServiceClient;
import com.google.cloud.batch.v1.Task;
import java.io.IOException;

public class ListTasks {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    // Project ID or project number of the Cloud project you want to use.
    String projectId = "YOUR_PROJECT_ID";
    // Name of the region hosts the job.
    String region = "europe-central2";
    // Name of the job which tasks you want to list.
    String jobName = "JOB_NAME";
    // Name of the group of tasks. Usually it's `group0`.
    String groupName = "group0";

    listTasks(projectId, region, jobName, groupName);
  }

  // Get a list of all jobs defined in given region.
  public static void listTasks(String projectId, String region, String jobName, String groupName)
      throws IOException {
    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `batchServiceClient.close()` method on the client to safely
    // clean up any remaining background resources.
    try (BatchServiceClient batchServiceClient = BatchServiceClient.create()) {

      String parent = String.format("projects/%s/locations/%s/jobs/%s/taskGroups/%s", projectId,
          region, jobName, groupName);
      for (Task task : batchServiceClient.listTasks(parent).iterateAll()) {
        System.out.println(task.getName());
      }
    }
  }
}

Node.js

Node.js

詳細については、Batch Node.js API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

/**
 * TODO(developer): Uncomment and replace these variables before running the sample.
 */
// const projectId = 'YOUR_PROJECT_ID';
/**
 * The region that hosts the job.
 */
// const region = 'us-central-1';
/**
 * The name of the job which tasks you want to list.
 */
// const jobName = 'YOUR_JOB_NAME';
/**
 * The name of the group of tasks. Usually it's `group0`.
 */
// const groupName = 'group0';

// Imports the Batch library
const batchLib = require('@google-cloud/batch');

// Instantiates a client
const batchClient = new batchLib.v1.BatchServiceClient();

async function callListTasks() {
  // Construct request
  const request = {
    parent: `projects/${projectId}/locations/${region}/jobs/${jobName}/taskGroups/${groupName}`,
  };

  // Run request
  const iterable = await batchClient.listTasksAsync(request);
  for await (const response of iterable) {
    console.log(response);
  }
}

await callListTasks();

Python

Python

詳細については、Batch Python API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

from __future__ import annotations

from collections.abc import Iterable

from google.cloud import batch_v1


def list_tasks(
    project_id: str, region: str, job_name: str, group_name: str
) -> Iterable[batch_v1.Task]:
    """
    Get a list of all jobs defined in given region.

    Args:
        project_id: project ID or project number of the Cloud project you want to use.
        region: name of the region hosting the jobs.
        job_name: name of the job which tasks you want to list.
        group_name: name of the group of tasks. Usually it's `group0`.

    Returns:
        An iterable collection of Task objects.
    """
    client = batch_v1.BatchServiceClient()

    return client.list_tasks(
        parent=f"projects/{project_id}/locations/{region}/jobs/{job_name}/taskGroups/{group_name}"
    )

C++

C++

詳細については、Batch C++ API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

#include "google/cloud/batch/v1/batch_client.h"

  [](std::string const& project_id, std::string const& location_id,
     std::string const& job_id, std::string const& group_id) {
    auto const parent = "projects/" + project_id + "/locations/" + location_id +
                        "/jobs/" + job_id + "/taskGroups/" + group_id;
    // Initialize a client and issue the request.
    auto client = google::cloud::batch_v1::BatchServiceClient(
        google::cloud::batch_v1::MakeBatchServiceConnection());
    int i = 0;
    for (auto task : client.ListTasks(parent)) {
      if (!task) throw std::move(task).status();
      std::cout << "Task[" << i++ << "]  " << task->DebugString() << "\n";
    }
  }

タスクの詳細を表示する

タスクの詳細は、Google Cloud コンソール、gcloud CLI、Batch API、Go、Java、Node.js、Python、C++ を使用して表示できます。

コンソール

重要: タスクに関するすべての情報を表示するには、gcloud CLI、Batch API、またはクライアント ライブラリを使用します。

Google Cloud コンソールを使用してタスクの詳細を表示するには、ジョブの詳細を表示して [ジョブの詳細] ページを開きます。次に、[タスクの詳細] セクションを確認します。

gcloud

gcloud CLI を使用してタスクの詳細を表示するには、次のフラグを指定して gcloud batch tasks describe コマンドを使用します。

gcloud batch tasks describe TASK_INDEX \
  --location=LOCATION \
  --job=JOB_NAME \
  --task_group=TASK_GROUP_NAME

以下を置き換えます。

• TASK_INDEX: 詳細を表示するタスクのインデックス。タスクグループでは、最初のタスクのタスク インデックスは 0 から始まり、タスクを追加するごとに 1 ずつ増加します。たとえば、4 つのタスクを含むタスクグループには、インデックス 0、1、2、3 が設定されます。

• TASK_GROUP_NAME: 詳細を表示するタスクを含むタスクグループの名前。値は group0 に設定する必要があります。

• JOB_NAME: 既存のジョブの名前。

• LOCATION: ジョブが存在するロケーション。

API

Batch API を使用してタスクの詳細を表示するには、tasks.get メソッドに GET リクエストを行います。

GET https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs/JOB_NAME/taskGroups/TASK_GROUP_NAME/tasks/TASK_INDEX

以下を置き換えます。

• PROJECT_ID: 現在のプロジェクトのプロジェクト ID。

• LOCATION: ジョブが存在するロケーション。

• JOB_NAME: 既存のジョブの名前。

• TASK_GROUP_NAME: 詳細を表示するタスクを含むタスクグループの名前。値は group0 に設定する必要があります。

• TASK_INDEX: 詳細を表示するタスクのインデックス。タスクグループでは、最初のタスクのタスク インデックスは 0 から始まり、タスクを追加するごとに 1 ずつ増加します。たとえば、4 つのタスクを含むタスクグループには、インデックス 0、1、2、3 が設定されます。

Go

Go

詳細については、Batch Go API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import (
	"context"
	"fmt"
	"io"

	batch "cloud.google.com/go/batch/apiv1"
	"cloud.google.com/go/batch/apiv1/batchpb"
)

// Retrieves the information about the specified job, most importantly its status
func getTask(w io.Writer, projectID, region, jobName, taskGroup string, taskNumber int32) error {
	// projectID := "your_project_id"
	// region := "us-central1"
	// jobName := "some-job"
	// taskGroup := "group0" // defaults to "group0" on job creation unless overridden
	// taskNumber := 0

	ctx := context.Background()
	batchClient, err := batch.NewClient(ctx)
	if err != nil {
		return fmt.Errorf("NewClient: %w", err)
	}
	defer batchClient.Close()

	req := &batchpb.GetTaskRequest{
		Name: fmt.Sprintf("projects/%s/locations/%s/jobs/%s/taskGroups/%s/tasks/%d",
			projectID, region, jobName, taskGroup, taskNumber),
	}

	response, err := batchClient.GetTask(ctx, req)
	if err != nil {
		return fmt.Errorf("unable to get task: %w", err)
	}

	fmt.Fprintf(w, "Task info: %v\n", response)

	return nil
}

Java

Java

詳細については、Batch Java API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import com.google.cloud.batch.v1.BatchServiceClient;
import com.google.cloud.batch.v1.Task;
import com.google.cloud.batch.v1.TaskName;
import java.io.IOException;

public class GetTask {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    // Project ID or project number of the Cloud project you want to use.
    String projectId = "YOUR_PROJECT_ID";
    // Name of the region hosts the job.
    String region = "europe-central2";
    // The name of the job you want to retrieve information about.
    String jobName = "JOB_NAME";
    // The name of the group that owns the task you want to check. Usually it's `group0`.
    String groupName = "group0";
    // Number of the task you want to look up.
    int taskNumber = 0;

    getTask(projectId, region, jobName, groupName, taskNumber);
  }

  // Retrieve information about a Task.
  public static void getTask(String projectId, String region, String jobName, String groupName,
      int taskNumber) throws IOException {
    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the `batchServiceClient.close()` method on the client to safely
    // clean up any remaining background resources.
    try (BatchServiceClient batchServiceClient = BatchServiceClient.create()) {

      Task task = batchServiceClient.getTask(TaskName.newBuilder()
          .setProject(projectId)
          .setLocation(region)
          .setJob(jobName)
          .setTaskGroup(groupName)
          .setTask(String.valueOf(taskNumber))
          .build());
      System.out.printf("Retrieved task information: %s", task.getName());
    }
  }
}

Node.js

Node.js

詳細については、Batch Node.js API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

/**
 * TODO(developer): Uncomment and replace these variables before running the sample.
 */
// const projectId = 'YOUR_PROJECT_ID';
/**
 * The region that hosts the job.
 */
// const region = 'us-central-1';
/**
 * The name of the job you want to retrieve information about.
 */
// const jobName = 'YOUR_JOB_NAME';
/**
 * The name of the group that owns the task you want to check.
 * Usually it's `group0`.
 */
// const groupName = 'group0';
/**
 * The number of the task you want to look up.
 */
// const taskNumber = 0;

// Imports the Batch library
const batchLib = require('@google-cloud/batch');

// Instantiates a client
const batchClient = new batchLib.v1.BatchServiceClient();

async function callGetJob() {
  // Construct request
  const request = {
    name:
      `projects/${projectId}/locations/${region}/jobs/${jobName}` +
      `/taskGroups/${groupName}/tasks/${taskNumber}`,
  };

  // Run request
  const response = await batchClient.getTask(request);
  console.log(response);
}

await callGetJob();

Python

Python

詳細については、Batch Python API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

from google.cloud import batch_v1


def get_task(
    project_id: str, region: str, job_name: str, group_name: str, task_number: int
) -> batch_v1.Task:
    """
    Retrieve information about a Task.

    Args:
        project_id: project ID or project number of the Cloud project you want to use.
        region: name of the region hosts the job.
        job_name: the name of the job you want to retrieve information about.
        group_name: the name of the group that owns the task you want to check. Usually it's `group0`.
        task_number: number of the task you want to look up.

    Returns:
        A Task object representing the specified task.
    """
    client = batch_v1.BatchServiceClient()

    return client.get_task(
        name=f"projects/{project_id}/locations/{region}/jobs/{job_name}"
        f"/taskGroups/{group_name}/tasks/{task_number}"
    )

C++

C++

詳細については、Batch C++ API のリファレンス ドキュメントをご覧ください。

Batch への認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

#include "google/cloud/batch/v1/batch_client.h"

  [](std::string const& project_id, std::string const& location_id,
     std::string const& job_id, std::string const& group_id,
     std::string const& task_number) {
    auto const name = "projects/" + project_id + "/locations/" + location_id +
                      "/jobs/" + job_id + "/taskGroups/" + group_id +
                      "/tasks/" + task_number;
    // Initialize a client and issue the request.
    auto client = google::cloud::batch_v1::BatchServiceClient(
        google::cloud::batch_v1::MakeBatchServiceConnection());
    auto response = client.GetTask(name);
    if (!response) throw std::move(response).status();
    std::cout << "GetTask() succeeded with " << response->DebugString() << "\n";
  }

次のステップ

• トラブルシューティングについて学習する。

• ジョブをモニタリングし、分析する方法を学習する。

  • ジョブのステータス イベントの履歴を表示する。

  • 指標を表示してジョブリソースをモニタリングして最適化する。

  • ジョブにログを構成した場合は、ログを使用してジョブを分析できます。

  • ステータス通知を構成した場合は、Pub/Sub 通知を使用してジョブをモニタリングし、BigQuery を使用して通知を分析できます。

• ジョブの管理方法を学習する。

  • ラベルを使用してリソースを整理する。

  • ジョブをキャンセルする（プレビュー）。

  • ジョブ情報をエクスポートする。

  • ジョブを削除する。