main:
    params: [input]
    steps:
    - 設定値割当:
        assign:
            - sourceBucket: バケット名を入力
            - destinationBucket: ${sourceBucket}
            - sourceObject: sample-file.txt
            - destinationObject: ${"copied-" + sourceObject}

    - copy(api):
        call: googleapis.storage.v1.objects.copy
        args:
            destinationBucket: ${destinationBucket}  #コピー先バケット
            destinationObject: ${destinationObject}  #コピー先オブジェクト
            sourceBucket: ${sourceBucket}            #コピー元バケット
            sourceObject: ${sourceObject}            #コピー元オブジェクト
            body:

    - delete(api):
        call: googleapis.storage.v1.objects.delete
        args:
            bucket: ${destinationBucket}
            object: ${destinationObject}

    - get(API):
        call: googleapis.storage.v1.objects.get
        args:
            bucket: ${sourceBucket}
            object: ${sourceObject}
            query:
              alt: media
        result: getResultApi
    - ログ出力:
        call: sys.log
        args:
            text: ${getResultApi}
            severity: INFO

main:
    steps:
    - 設定値割当:
        assign:
            - sourceBucket: バケット名を入力                    #コピー元バケット
            - destinationBucket: ${sourceBucket}              #コピー先バケット
            - sourceObject: sample-file.txt                   #コピー元オブジェクト
            - destinationObject: ${"copied-" + sourceObject}  #コピー先オブジェクト
    - copy(http):
        call: http.post
        args:
            url: '${"https://storage.googleapis.com/storage/v1/b/"+sourceBucket+"/o/"+sourceObject+"/copyTo/b/"+destinationBucket+"/o/"+destinationObject}'
            auth:
              type: OAuth2
    - delete(http):
        call: http.delete
        args:
            url: '${"https://storage.googleapis.com/storage/v1/b/"+destinationBucket+"/o/"+destinationObject}'
            auth:
              type: OAuth2
    - get(HTTP):
        call: http.get
        args:
          url: '${"https://storage.googleapis.com/download/storage/v1/b/"+sourceBucket+"/o/"+sourceObject}'
          auth:
            type: OAuth2
          query:
            alt: media
        result: getResultHttp
    - ログ出力:
        call: sys.log
        args:
            text: ${getResultHttp["body"]}
            severity: INFO

main:
    steps:
    - 設定値割当:
        assign:
            # Project
            - projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
            # Workflow
            - workflowLocation: asia-northeast1    #起動するワークフローのロケーション
            - workflowName: triggered-workflow     #起動するワークフロー名
    - Workflow起動ログ:
        call: sys.log
        args:
          text: '${"ワークフローを起動します。フロー名：" + workflowName}'
          severity: INFO
    - Workflow起動処理:
        call: http.post
        args:
            url: ${"https://workflowexecutions.googleapis.com/v1/projects/" + projectId + "/locations/" + workflowLocation + "/workflows/" + workflowName + "/executions"}
            body:
                argument: "{\"parameter1\": \"trigger-test1\",\"parameter2\": \"trigger-test2\"}"
            auth:
                type: OAuth2

main:
    params: [input]
    steps:
    - トリガー元からの引数をログに出力:
        call: sys.log
        args:
          text: '${"引数1:" + input.parameter1 + ", 引数2:" + input.parameter2}'
          severity: INFO

from flask import jsonify

def main(request):
    param_dict = request.get_json()
    parameter1 = param_dict["parameter1"]
    parameter2 = param_dict["parameter2"]

    if parameter1 > parameter2:
      bigger_value = parameter1
    else:
      bigger_value = parameter2

    msg = "関数の呼び出しに成功しました。"
    return jsonify({'message': msg, 'biggerValue': bigger_value})　

次に、下記のコードのワークフローを作成します。

main:
    params: [input]
    steps:
    - 設定値割当:
        assign:
            # Project
            - projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
            # Cloud Functions
            - functionName: workflow-test
            - functionLocation: asia-northeast1
            - value1: ${input.value1}
            - value2: ${input.value2}
    - function実行:
        call: http.post
        args:
            url: ${"https://" + functionLocation + "-" + projectId + ".cloudfunctions.net/" + functionName}
            body:
                parameter1: ${value1}
                parameter2: ${value2}
            auth:
                type: OIDC
        result: functionResult
    - ログ出力（メッセージ）:
        call: sys.log
        args:
          text: ${functionResult.body.message}
          severity: INFO
    - ログ出力（大きい値）:
        call: sys.log
        args:
          text: ${functionResult.body.biggerValue}
          severity: INFO

ランタイム引数に設定する2つの値をCloud Functions関数に渡し、戻り値をログに出力する処理です。
httpリクエストのbodyで、Cloud Functions関数に渡す引数（parameter1, parameter2）を設定しています。

ランタイム引数を設定して、ワークフローを実行してみます。

Cloud Functions関数の呼び出しに成功し、受け取った値（メッセージと大きい方の値）がログに出力されました。

まとめ

今回は、Cloud Storage内のオブジェクトへの処理、他のワークフローの呼び出し、Cloud Functions関数の呼び出しについて書いてみました！
本記事で紹介した内容以外にも、様々な処理を呼び出すことができます。
是非みなさんもWorkflowsを使ってみてくださいね！

当社、システムサポートは、Google Cloudの導入・移行・運営支援を行っています。
Google Cloud に関してのご用命の際は「クラウド導入支援サービス for Google Cloud」へご連絡ください。