Go부터 Workflows 실행

개시하다

Go부터 실행할게요.

package main

import (
	"context"
	"fmt"

	"google.golang.org/api/workflowexecutions/v1"
	"google.golang.org/api/workflows/v1"
)

const (
	projectID = "YOUR_PROJECT_ID"
	location  = "YOUR_LOCATION"
)

func main() {

	ctx := context.Background()

	// workflowリストを取得
	var targetWorkflowName string
	{
		workflow, err := workflows.NewService(ctx)
		if err != nil {
			panic(err)
		}

		// 指定したプロジェクトID・ロケーションのワークフロー一覧を取得
		parent := fmt.Sprintf("projects/%s/locations/%s", projectID, location)
		resp, err := workflow.Projects.Locations.Workflows.List(parent).Do()
		if err != nil {
			panic(err)
		}

		for _, workflow := range resp.Workflows {

			// ワークフロー名を出力
			fmt.Println(workflow.Name)

			// 最終ループのワークフロー名を代入（※雑なコードなのはご容赦）
			targetWorkflowName = workflow.Name
		}
	}

	// targetWorkflowNameを実行する
	workflowExecService, err := workflowexecutions.NewService(ctx)
	if err != nil {
		panic(err)
	}

	// ワークフローの実行
	// e.g. targetWorkflowName="projects/{PROJECT_ID}/locations/{LOCATION}/workflows/{WORKFLOW_NAME}"
	exe, err := workflowExecService.Projects.Locations.Workflows.Executions.Create(targetWorkflowName, &workflowexecutions.Execution{
		Name: targetWorkflowName,
	}).Do()
	if err != nil {
		panic(err)
	}

	// 実行結果出力
	fmt.Println(exe.Name)
}

추가 참조 링크