別の記事でGKE上にバッチジョブを稼働させる方法を紹介しましたが、今回稼働スケジュールも設定してジョブデプロイする方法を紹介したいと思っております。

早速ですが、実施手順のまとめは下記となります。

バッチジョブ作成
イメージをビルドして、Container Registryにプッシュ
ジョブ稼働スケジュールを設定し、デプロイする

※本手順はGCPとgcloudコマンドの利用経験があることが望ましいです。

ワークフォルダの構成

cron_job
├── build
│   ├── cloudbuild.cronjob.yaml
│   └── simplejob.Dockerfile
├── deployment
│   └── cronjob.deployment.yaml
├── go.mod
├── go.sum
└── job
    ├── handler
    │   └── simplejob_handler.go
    └── simplejob.go

1.　バッチジョブ作成

go言語を使って、簡単なバッチジョブを作成します。

simplejob.go

package main

import (
	"context"
	"log"

	"github.com/itdevsamurai/gke/cronjob/job/handler"
)

func main() {
	log.Println("Job Started.")

	ctx := context.Background()
	handler.SimpleJobHandler{}.Run(ctx)

	log.Println("Job Finished.")
}

simplejob_handler.go

package handler

import (
	"context"
	"flag"
	"log"
	"os/exec"
)

type SimpleJobHandler struct {
}

func (j SimpleJobHandler) Run(ctx context.Context) error {
	log.Println("Processing ...")

	runTime := getArguments()
	cmd := exec.Command("sleep", runTime)
	err := cmd.Run()
	if err != nil {
		log.Printf("Error at command: %v", cmd)
		return err
	}

	log.Println("Process completed.")
	return nil
}

func getArguments() string {
	runTime := flag.String("run-time", "", "specify number of seconds to run job")
	flag.Parse()
	return *runTime
}

このバッチジョブはインプットパラメータで稼働時間（何秒か）を指定する。

ローカルで稼働させてみる

cd path_to_cronjob
go run job/simplejob.go --run-time=5

2.　イメージをビルドして、Container Registryにプッシュ

Cloud buildを使ってDockerイメージのビルドとContainer Registryにプッシュを行います。

simplejob.Dockerfile

FROM golang:1.12 as build_env

WORKDIR /go/src/github.com/itdevsamurai/gke/cronjob

COPY ./job ./job
COPY go.mod ./

ENV PATH="${PATH}:$GOPATH/bin"
ENV GO111MODULE=on

RUN export GOPROXY="https://proxy.golang.org" && export GO111MODULE=on && CGO_ENABLED=0 go build -o simplejob job/simplejob.go

FROM alpine:latest
WORKDIR /app
COPY --from=build_env /go/src/github.com/itdevsamurai/gke/cronjob /job

cloudbuild.cronjob.yaml

options:
  env:
  - GO111MODULE=on
  volumes:
  - name: go-modules
    path: /go

steps:
# go test
- name: golang:1.12
  dir: .
  args: ['go', 'test', './...']

# go build
- name: golang:1.12
  dir: .
  args: ['go', 'build', '-o', 'simplejob', 'job/simplejob.go']
  env: ["CGO_ENABLED=0"]

# docker build
- name: 'gcr.io/cloud-builders/docker'
  dir: .
  args: [
         'build',
         '-t', '${_GCR_REGION}/${_GCR_PROJECT}/${_GCR_IMAGE_NAME}:${_GCR_TAG}',
         '-f', 'build/simplejob.Dockerfile',
         '--cache-from', '${_GCR_REGION}/${_GCR_PROJECT}/${_GCR_IMAGE_NAME}:${_GCR_TAG}',
         '.'
        ]

# push image to Container Registry
- name: 'gcr.io/cloud-builders/docker'
  args: ["push", '${_GCR_REGION}/${_GCR_PROJECT}/${_GCR_IMAGE_NAME}']

substitutions:
  # # GCR region name to push image
  _GCR_REGION: asia.gcr.io
  # # Project ID
  _GCR_PROJECT: project-abc123
  # # Image name
  _GCR_IMAGE_NAME: simple-job
  # # Image tag
  _GCR_TAG: latest

イメージビルドとプッシュ実行

cd cronjob_folder

gcloud builds submit --config build/cloudbuild.cronjob.yaml

実施後確認

3. ジョブ稼働スケジュールを設定し、デプロイする

デプロイメント定義ファイル作成

cronjob.deployment.yaml

apiVersion: batch/v1beta1
kind: CronJob
metadata:
  name: simple-cron-job
spec:
  schedule: "*/5 * * * *"
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: simple-cron-job-container
            image: asia.gcr.io/project-abc123/simple-job:latest
            command: ["/job/simplejob"]
            args: ["--run-time", "10"]
          restartPolicy: Never

稼働スケジュールの設定は spec.schedule フィールドで指定します。
spec.schedule フィールドは、UNIX 標準の crontab 形式を使用して CronJob を実行する時間と間隔を定義します。すべての CronJob 時間は UTC で表示されます。スペースで区切られた 5 つのフィールドがあります。これらのフィールドは、以下を表します。

分（0～59）
時間（0～23）
日（1～31）
月（1～12）
曜日（0～6）
すべての spec.schedule フィールドで、次の特殊文字を使用できます。

? は、単一の文字と一致するワイルドカード値です。

は、ゼロ個以上の文字と一致するワイルドカード値です。
/ を使用すると、フィールドの間隔を指定できます。たとえば、最初のフィールド（分フィールド）の値が */5 の場合、「5 分ごと」を意味します。5 番目のフィールド（曜日フィールド）が 0/5 に設定されている場合、「5 回目の日曜日ごと」を意味します。

最後はジョブデプロイを実施します。

cd cronjob_folder

# スケジュールされたジョブをデプロイする
kubectl apply -f deployment/cronjob.deployment.yaml

デプロイ後の確認

これまでスケジュール稼働ジョブデプロイは完了となります。

本記事で利用したソースコードはこちら

https://github.com/dssolutioninc/dss_gke/tree/master/cronjob

最後まで読んで頂き、どうも有難う御座います!

DSS 橋本

1. バッチジョブ作成

2. イメージをビルドして、Container Registryにプッシュ

3. ジョブ稼働スケジュールを設定し、デプロイする

1.　バッチジョブ作成

2.　イメージをビルドして、Container Registryにプッシュ