Workflows / Cloud Tasks 完全ガイド｜サーバレスオーケストレーション

Workflows と Cloud Tasks は GCP のサーバレスオーケストレーションサービスです。 Workflows は API/Service の順序実行、Cloud Tasks は非同期タスクキュー。両者を使い分けることでサーバレスで複雑なフローを構築できます。

Workflows

主要機能

• サーバレス、YAML / JSON ベース
• HTTP / GCP API / Cloud Functions / Cloud Run 連携
• 制御構造: parallel、for ループ、try-except、switch
• 最大実行時間 1 年
• Connector で GCP サービス 50+ をワンクリック呼び出し
• Eventarc 統合でイベント駆動

Workflow YAML 例

main:
  params: [input]
  steps:
    - validate:
        call: http.post
        args:
          url: https://api.example.com/validate
          body: ${input}
        result: validation
    - check:
        switch:
          - condition: ${validation.body.valid}
            next: process
          - condition: true
            return: "Invalid input"
    - process:
        parallel:
          shared: [result]
          branches:
          - charge:
              steps:
              - call_charge:
                  call: googleapis.cloudfunctions.v2.functions.call
                  args:
                    name: projects/PROJECT/locations/asia-northeast1/functions/charge
                    body: ${input}
                  result: result.charge
          - notify:
              steps:
              - call_notify:
                  call: googleapis.cloudfunctions.v2.functions.call
                  args:
                    name: projects/PROJECT/locations/asia-northeast1/functions/notify
                    body: ${input}
                  result: result.notify
    - return:
        return: ${result}

Cloud Tasks

主要機能

• HTTP ターゲット + App Engine ターゲット
• 遅延実行 (scheduleTime)
• Rate Limit (Token Bucket / Concurrent)
• Retry 設定 (max attempts / min backoff / max backoff)
• Dead Letter Queue 対応
• OIDC / OAuth トークン自動付与

タスク作成例 (Python)

from google.cloud import tasks_v2

client = tasks_v2.CloudTasksClient()
parent = client.queue_path('PROJECT', 'asia-northeast1', 'my-queue')

task = {
    "http_request": {
        "http_method": tasks_v2.HttpMethod.POST,
        "url": "https://my-service.run.app/process",
        "body": json.dumps({"user_id": 123}).encode(),
        "headers": {"Content-Type": "application/json"},
        "oidc_token": {
            "service_account_email": "[email protected]",
        },
    },
    "schedule_time": datetime.utcnow() + timedelta(minutes=10),
}
response = client.create_task(parent=parent, task=task)

料金

使い分けマトリクス

典型的なユースケース

Workflows

• 顧客オンボーディング (Auth → DB 登録 → メール送信 → Slack 通知)
• Vertex AI 推論パイプライン (画像取得 → 前処理 → 推論 → 結果保存)
• マルチクラウド連携 (AWS S3 → Dataflow → BQ)

Cloud Tasks

• ユーザー通知の遅延送信 (登録後 24 時間)
• Webhook の Rate Limit 制御
• レポート生成の非同期処理
• 外部 API への安定したコール (Retry + Backoff)

他クラウド比較

※ Google Cloud は Google LLC の商標です。最新情報は Workflows 公式 をご確認ください。