Snowflake Serverless Tasks 完全ガイド: ウェアハウス不要のタスク実行

Snowflake Serverless Tasksは、仮想ウェアハウスを事前に作成・管理することなく、SnowflakeがSQL文やストアドプロシージャを自動実行するタスク基盤です。 コンピュートの起動・サイジング・停止をSnowflakeが自動管理するため、運用オーバーヘッドが大幅に削減されます。

Serverless Tasks vs User-managed Tasks

SnowflakeのタスクにはServerless Tasks（ウェアハウス不要）とUser-managed Tasks（WAREHOUSE句でウェアハウスを指定）の2種類があります。 違いを正確に理解することが試験対策でも実務設計でも重要です。

Serverless Taskの作成SQL

Serverless TaskではWAREHOUSE句を省略し、代わりにUSER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZEパラメータでコンピュートの初期サイズを指定します。

-- Serverless Task の作成
CREATE OR REPLACE TASK etl_daily_aggregate
  USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE = 'MEDIUM'
  SCHEDULE = 'USING CRON 0 2 * * * Asia/Tokyo'
  ERROR_ON_NONDETERMINISTIC_MERGE = FALSE
AS
  MERGE INTO analytics.daily_summary AS tgt
  USING (
    SELECT
      event_date,
      COUNT(*) AS event_count,
      SUM(revenue) AS total_revenue
    FROM raw.events
    WHERE event_date = CURRENT_DATE() - 1
    GROUP BY event_date
  ) AS src
  ON tgt.event_date = src.event_date
  WHEN MATCHED THEN UPDATE SET
    event_count = src.event_count,
    total_revenue = src.total_revenue
  WHEN NOT MATCHED THEN INSERT
    (event_date, event_count, total_revenue)
    VALUES (src.event_date, src.event_count, src.total_revenue);

対比として、User-managed Taskは以下のようにWAREHOUSE句を指定します。

-- User-managed Task の作成
CREATE OR REPLACE TASK etl_daily_aggregate_wh
  WAREHOUSE = etl_warehouse
  SCHEDULE = 'USING CRON 0 2 * * * Asia/Tokyo'
AS
  MERGE INTO analytics.daily_summary AS tgt
  USING (...) AS src
  ON tgt.event_date = src.event_date
  WHEN MATCHED THEN UPDATE SET ...
  WHEN NOT MATCHED THEN INSERT ...;

タスクDAG（依存関係チェーン）

Serverless TasksでもAFTER句でタスクの依存関係を定義してDAGを構築できます。 ルートタスク（SCHEDULEを持つ最上位タスク）の実行完了後に子タスクが順次起動します。

-- ルートタスク（Serverless）
CREATE OR REPLACE TASK dag_root
  USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE = 'SMALL'
  SCHEDULE = 'USING CRON 0 3 * * * Asia/Tokyo'
AS
  INSERT INTO staging.raw_data
  SELECT * FROM external_table WHERE loaded = FALSE;

-- 子タスク1（Serverless）
CREATE OR REPLACE TASK dag_transform
  USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE = 'MEDIUM'
  AFTER dag_root
AS
  INSERT INTO analytics.transformed
  SELECT ... FROM staging.raw_data WHERE ...;

-- 子タスク2（Serverless）
CREATE OR REPLACE TASK dag_quality_check
  USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE = 'XSMALL'
  AFTER dag_transform
AS
  CALL quality_check_sp('analytics.transformed');

-- DAGの起動（ルートからRESUME）
ALTER TASK dag_quality_check RESUME;
ALTER TASK dag_transform RESUME;
ALTER TASK dag_root RESUME;

権限設計

Serverless Tasksを使用するには、タスクの所有ロールに対して アカウントレベルのEXECUTE MANAGED TASK権限を付与する必要があります。 User-managed TasksのUSAGE ON WAREHOUSE権限とは異なる権限体系です。

-- Serverless Task用の権限付与
GRANT EXECUTE MANAGED TASK ON ACCOUNT
  TO ROLE etl_role;

-- タスク作成権限（Serverless/User-managed共通）
GRANT CREATE TASK ON SCHEMA analytics
  TO ROLE etl_role;

-- User-managed Taskの場合はウェアハウス権限が必要
GRANT USAGE ON WAREHOUSE etl_warehouse
  TO ROLE etl_role;

コスト見積もり

Serverless Tasksのコスト履歴はSNOWFLAKE.ACCOUNT_USAGE.SERVERLESS_TASK_HISTORYビューで確認できます。 User-managed TasksのコストはWAREHOUSE_METERING_HISTORYから確認します。

-- Serverless Taskのクレジット消費を日別に集計
SELECT
  DATE_TRUNC('DAY', START_TIME) AS exec_date,
  TASK_NAME,
  COUNT(*) AS exec_count,
  SUM(CREDITS_USED) AS total_credits
FROM SNOWFLAKE.ACCOUNT_USAGE.SERVERLESS_TASK_HISTORY
WHERE START_TIME >= DATEADD('DAY', -30, CURRENT_TIMESTAMP())
GROUP BY exec_date, TASK_NAME
ORDER BY total_credits DESC;

-- タスクの実行履歴を確認
SELECT *
FROM TABLE(INFORMATION_SCHEMA.TASK_HISTORY(
  TASK_NAME => 'ETL_DAILY_AGGREGATE',
  SCHEDULED_TIME_RANGE_START => DATEADD('DAY', -7, CURRENT_TIMESTAMP())
))
ORDER BY SCHEDULED_TIME DESC;

運用モニタリング

タスクが失敗した場合はALERT機能やNotification Integrationと組み合わせて検知します。 TASK_HISTORYのSTATE列が'FAILED'の場合にERROR_MESSAGEから原因を特定します。

-- 直近の失敗タスクを抽出
SELECT
  NAME,
  SCHEDULED_TIME,
  STATE,
  ERROR_CODE,
  ERROR_MESSAGE
FROM TABLE(INFORMATION_SCHEMA.TASK_HISTORY(
  RESULT_LIMIT => 100
))
WHERE STATE = 'FAILED'
ORDER BY SCHEDULED_TIME DESC;

試験で問われるポイント

• Serverless TaskではWAREHOUSE句を指定せず、USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZEを使う
• 必要な権限はEXECUTE MANAGED TASK ON ACCOUNT（User-managedのUSAGE ON WAREHOUSEとは異なる）
• Serverless Credit倍率（1.5倍）だがアイドルコスト0の課金特性
• AFTER句によるDAG構築はServerless/User-managed両方で可能
• コスト確認はSERVERLESS_TASK_HISTORYビュー

問題で確認

よくある質問