タスクの紹介¶

制限事項¶

• サーバーレスタスクの最大コンピュートサイズは X2LARGE 仮想ウェアハウス に相当します。

サーバーレス・コンピュート・モデルを使ったタスクの作成¶

CREATE TASK または ALTER TASK を使用する場合は、 WAREHOUSE パラメーターを省略します。

タスクを実行するロールは、グローバル EXECUTE MANAGED TASK 権限を持っている必要があります。タスクのアクセス制御要件の詳細については、 タスクセキュリティ をご参照ください。

以下のパラメーターをセットすることで、サーバーレスタスクのコストとパフォーマンスをある程度コントロールすることができます。

• SERVERLESS_TASK_MAX_STATEMENT_SIZE：想定外のコストを防ぐため、ウェアハウスの最大サイズを設定します。

• SERVERLESS_TASK_MIN_STATEMENT_SIZE：予測可能なパフォーマンスのためのウェアハウスの最小サイズ。

• TARGET_COMPLETION_INTERVAL：タスクの完了時間を指定します。

これらのセットが指定された場合、優先順位は以下のようになります。

• SERVERLESS_TASK_MAX_STATEMENT_SIZE

• SERVERLESS_TASK_MIN_STATEMENT_SIZE

• TARGET_COMPLETION_INTERVAL

Snowflakeがサーバーレスのコンピュートリソースを推定する方法¶

Snowflakeは、ターゲット時間枠と以前のタスク実行のパフォーマンスに基づいて、タスクを完了するために必要な計算リソースを自動的に推定します。

ターゲットの時間枠は TARGET_COMPLETION_INTERVAL でセットできます。この値がセットされていない場合、Snowflakeはサーバーレスのコンピュートリソースのサイズを変更して、次の実行スケジュール時刻までに完了するようにします。

タスクが完了すると、Snowflakeは必要な計算リソースを次のように見積もります。

• タスクの完了が早すぎる場合（ターゲット時間より1ファクター短い時間内に完了する場合）、Snowflakeは以降の実行でリソースを1つずつスケールダウンします（ウェアハウスサイズ）。

• タスクの完了が遅すぎる場合（ターゲット時間枠を1倍上回る時間枠内）、Snowflakeは以降の実行でリソースを1つずつスケールアップします（ウェアハウスサイズ）。

例¶

例1：1 時間ごとに実行するサーバーレスタスクを作成し、完了間隔を 120 分にターゲットします。

CREATE TASK SCHEDULED_T1 SCHEDULE='USING CRON 0 * * * * America/Los_Angeles'
TARGET_COMPLETION_INTERVAL='120 MINUTE' AS SELECT 1;

TARGET_COMPLETION_INTERVAL に比較的長い継続時間をセットすることで、タスクの実行時間が長くなっても構わないことを示します。Snowflake は、タスクの実行が指定した TARGET_COMPLETION_INTERVAL 内で完了するように、サーバーレスコンピュートのサイズを自動的に調整します。

例2: 1時間ごとに実行するサーバーレスタスクを作成し、完了時間を10分にターゲットします。

CREATE TASK SCHEDULED_T2 SCHEDULE='USING CRON 0 * * * * UTC'
TARGET_COMPLETION_INTERVAL='10 MINUTE'
SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
AS SELECT 1;

TARGET_COMPLETION_INTERVAL に比較的短い時間をセットすることで、タスクを早く完了させることを好むことを示しています。Snowflakeは、 SERVERLESS_TASK_MAX_STATEMENT_SIZE に達するまで、タスクの実行が指定された TARGET_COMPLETION_INTERVAL 内で完了するように、サーバーレスコンピュートのサイズを自動的に調整します。

例3: 1日1回、ターゲット完了間隔と最小・最大ウェアハウスサイズの範囲内でスケジュールされるサーバーレスタスクを作成します。

CREATE TASK SCHEDULED_T3 SCHEDULE='USING CRON 0 0 * * * UTC'
TARGET_COMPLETION_INTERVAL='180 M'
SCHEDULING_MODE = 'FLEXIBLE'
SERVERLESS_TASK_MIN_STATEMENT_SIZE='MEDIUM' SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE' AS SELECT 1;

この構成では、サーバーレスタスクは少なくとも中規模ウェアハウスで1日1回深夜に実行され、 TARGET_COMPLETION_INTERVAL は3時間です。Snowflakeは、 SERVERLESS_TASK_MAX_STATEMENT_SIZE に達するまで、タスクの実行が指定された TARGET_COMPLETION_INTERVAL 内で完了するように、サーバーレスコンピュートのサイズを自動的に調整します。SCHEDULING_MODE をフレキシブルにセットすることで、タスクは日中いつでも開始できます。

例4: 1日1回、ターゲット完了間隔なしでスケジュールされるサーバーレスタスクを作成します。

CREATE TASK SCHEDULED_T4 SCHEDULE='USING CRON 0 0 * * * UTC'
SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE' AS SELECT 1;

この構成では、サーバーレスタスクは1日1回深夜に実行されます。一連のタスク実行時間が次のスケジュール時間までに完了しない場合、Snowflakeは自動的にサーバーレスコンピュートサイズを設定し、 SERVERLESS_TASK_MAX_STATEMENT_SIZE に達するまで指定された SCHEDULE 内でタスク実行が完了するようにします。

パラメーターと構文の詳細については、 CREATE TASK と ALTER TASK をご参照ください。

ウェアハウスのサイズの選択¶

既存のウェアハウスを使用して個々のタスクにコンピューティングリソースを提供することを選択する場合は、 ウェアハウスに関する考慮事項 で説明されているベストプラクティスに従ってください。タスクに必要なコンピューティングクラスタを理解するには、ウェアハウスのサイズとクラスタリングに基づいて異なるウェアハウスを使用して、単一のタスクまたは タスクグラフ の平均実行時間を分析します。ウェアハウスが複数のプロセスで共有されているかどうかも考慮する必要があります。

タスクの平均実行時間を分析するには、 TASK_HISTORY アカウント使用状況表示 をクエリします。タスクのスケジュールされた時間と完了した時間の平均差は、タスクの予想される平均実行時間です。この差には、他のプロセスがウェアハウスのコンピューティングリソースを使用している間、タスクがキューに入っていた時間も含まれます。

タスクグラフの場合、先行タスクの実行が完了し、子タスクが起動された後、短いラグがあります。ウェアハウスの大きさは、複数の子タスクが同時に実行できる大きさを選びます。

次の図は、20秒間キューに入れられた単一のタスクが40秒間実行された、1分間のウィンドウを示しています。これは、タスクがスケジュールされてから最初の20秒間、他のプロセスがウェアハウスのリソースを使用していたことを意味します。

次の図は、実行ごとに平均で5分かかるタスクグラフを示しています。この図は、タスクグラフを2回実行して完了するウィンドウを示しています。このウィンドウでは、ルートタスクの開始がスケジュールされている時間から、最後の子タスクの実行が完了するまでが計算されます。

この例では、タスクグラフが実行されているウェアハウスは、他の並行処理と共有されています。これらの同時操作は、タスクグラフ内の各タスクの実行が終了し、次のタスクの実行が開始される前に、使用可能なすべてのリソースを消費します。その結果、各タスクのウィンドウには、他の操作が終了してコンピューティングリソースの放棄を待つ間、ある程度のキューイングが含まれます。

タスクのスケジューリングと夏時間¶

タスク定義のcron式は、タイムゾーンの指定をサポートしています。標準時間から夏時間への移行（またはその逆）が発生するときにスケジュールされたタスクは、予期しない動作をする可能性があります。

例:

• 夏時間から標準時間への変更中に、米国/ロサンゼルスタイムゾーンの1 AM （0 1 * * * America/Los_Angeles）で開始するようにスケジュールされたタスクは、2回 実行されます。1AM、 そして1：59：59AMが現地時間の1：00：00AMにシフトしたときに再び実行されます。。

• 標準時間への夏時間の変更中、米国/ロサンゼルスタイムゾーンの2 AM （0 2 * * * America/Los_Angeles）で開始するようにスケジュールされたタスクは、ローカル時間が1：59：59 AMから3：00：00 AMへシフトするため実行されません。

夏時間による予期しないタスクの実行を避けるため、次を検討します。

• 1 AMから3 AMの間にタスクが実行されるようにスケジュールを組まないでください。

• 毎年2回、1 AMから3 AMの間にスケジュールされたタスクのcron式を手動で調整し、時間の変化を補正します。

• UTC など、夏時間を適用しない時刻形式を使用する。

トリガータスクの作成¶

CREATE TASK を使用し、 WHEN 句を使用してターゲット・ストリームを定義します。(SCHEDULE パラメーターは含めないでください）。

以下のいずれかを選択して、タスク の計算リソースを割り当てます。

• リソースを手動で管理（ユーザー管理ウェアハウスタスク）するには、 WAREHOUSE パラメーターを追加します。

• Snowflakeによるリソース管理（サーバーレスタスク）を許可するには、 TARGET_COMPLETION_INTERVAL パラメーターを追加します。Snowflakeは必要なリソースを見積もり、この時間でタスクを完了できるように調整します。

スケジュールタスクからトリガータスクへの移行¶

タスクを中断し、 SCHEDULE パラメーターの設定を解除して、タスクを再開します。既存のタスクには、 WHEN 句で定義されたターゲットストリームが必要です。

ALTER TASK task SUSPEND;
ALTER TASK task UNSET SCHEDULE;
ALTER TASK task RESUME;

ユーザー管理のトリガータスクからサーバーレスのトリガータスクへの移行¶

タスクを中断します。 WAREHOUSE パラメーターを削除し、 TARGET_COMPLETION_INTERVAL パラメーターを追加します。タスクを再開します。

トリガータスクに関する考察¶

• SHOW TASKS と DESC TASK 出力では、 SCHEDULE プロパティはトリガータスクのために NULL を表示します。

• information_schemaスキーマとaccount_usageスキーマのtask_historyビューの出力では、SCHEDULED_FROM列がTRIGGERと表示されます。

• 複数のデータストリームを扱う場合、 WHEN … AND と WHEN … OR という条件パラメーターを使用することで、タスクの開始タイミングを管理できます。

トリガータスクの制限¶

• デフォルトでは、トリガータスクは最大30秒ごとに実行されます。USER_TASK_MINIMUM_TRIGGER_INTERVAL_IN_SECONDS パラメーターを変更することで、より頻繁に、最大10秒ごとに実行することができます。

• ディレクトリテーブル、外部テーブル、ハイブリッドテーブルのストリームはサポートされていません。

トリガータスクの例¶

例1：2 つのス ト リ ームのいずれかでデータが変更されるときに実行されるユーザー管理タスク を作成します。

CREATE TASK my_task
  WHEN SYSTEM$STREAM_HAS_DATA('my_return_stream')
  OR   SYSTEM$STREAM_HAS_DATA('my_order_stream')
  WAREHOUSE = my_warehouse
  AS
    INSERT INTO customer_activity
    SELECT customer_id, return_total, return_date, ‘return’
    FROM my_return_stream
    UNION ALL
    SELECT customer_id, order_total, order_date, ‘order’
    FROM my_order_stream;

例2：2つの異なるデータストリームでデータ変更が検出されたときに実行するタスクを作成します。このタスクは AND 条件を使用するため、2つのストリームの一方にしか新しいデータがない場合、タスクはスキップされます。

TARGET_COMPLETION_INTERVAL は 120 分であるため、Snowflake はこの時間内にタスクを完了するために必要なコンピュートリソースを見積もり、調整します。

CREATE TASK triggeredTask
  WHEN SYSTEM$STREAM_HAS_DATA('orders_stream')
  TARGET_COMPLETION_INTERVAL='120 MINUTES'
  AS
    INSERT INTO completed_promotions
    SELECT order_id, order_total, order_time, promotion_id
    FROM orders_stream
    WHERE promotion_id IS NOT NULL;

タスクの作成¶

タスクを作成するには、少なくとも次の権限を持つロールが必要です。

タスクの実行¶

タスクが作成された後、タスク所有者はタスクを実行するために次の権限を持つ必要があります。

またロールは、タスクによって実行される SQL ステートメントの実行に必要な権限を持っている必要があります。

タスク履歴の表示¶

タスクを表示するには、以下の権限を1つ以上持っている必要があります。

• ACCOUNTADMINロール。

• タスクに対する OWNERSHIP 権限。

• MONITOR EXECUTION グローバル権限。

タスクの再開または中断¶

タスクの所有者に加えて、タスクに対するOPERATE権限を持つロールは、タスクを一時停止または再開できます。このロールには、タスクを含むデータベースとスキーマに対するUSAGE権限が必要です。他の権限は必要ありません。

タスクが再開されると、Snowflakeは、タスクの所有者のロールが タスクの実行 にリストされている権限を持っていることを確認します。

タスクを作成するカスタムロールの作成¶

Snowflakeは、サーバーレスタスクとユーザー管理タスクを作成するために異なる権限を必要とします。

例えば、ユーザが管理するタスクを作成するには、 warehouse_task_creation というカスタムロールを作成し、そのロールがタスクを作成できるウェアハウスで、 CREATE TASK と USAGE 権限をそのロールに付与します。

USE SYSADMIN;

CREATE ROLE warehouse_task_creation
  COMMENT = 'This role can create user-managed tasks.';

from snowflake.core.role import Role

root.session.use_role("SYSADMIN")

my_role = Role(
    name="warehouse_task_creation",
    comment="This role can create user-managed tasks."
)
root.roles.create(my_role)

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE warehouse_task_creation;

from snowflake.core.role import Securable

root.session.use_role("ACCOUNTADMIN")

root.roles['warehouse_task_creation'].grant_privileges(
    privileges=["CREATE TASK"], securable_type="schema", securable=Securable(name='schema1')
)

GRANT USAGE
  ON WAREHOUSE warehouse1
  TO ROLE warehouse_task_creation;

from snowflake.core.role import Securable

root.roles['warehouse_task_creation'].grant_privileges(
    privileges=["USAGE"], securable_type="warehouse", securable=Securable(name='warehouse1')
)

サーバーレスタスクを作成できるロールの例として、 serverless_task_creation というカスタムロールを作成し、そのロールに CREATE TASK 権限とアカウントレベル EXECUTE MANAGED TASK 権限を付与します。

USE SYSADMIN;

CREATE ROLE serverless_task_creation
  COMMENT = 'This role can create serverless tasks.';

from snowflake.core.role import Role

root.session.use_role("SYSADMIN")

my_role = Role(
    name="serverless_task_creation",
    comment="This role can create serverless tasks."
)
root.roles.create(my_role)

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE serverless_task_creation;

from snowflake.core.role import Securable

root.session.use_role("ACCOUNTADMIN")

root.roles['serverless_task_creation'].grant_privileges(
    privileges=["CREATE TASK"], securable_type="schema", securable=Securable(name='schema1')
)

GRANT EXECUTE MANAGED TASK ON ACCOUNT
  TO ROLE serverless_task_creation;

root.roles['serverless_task_creation'].grant_privileges(
    privileges=["EXECUTE MANAGED TASK"], securable_type="account"
)

タスクを管理するカスタムロールの作成¶

EXECUTE TASK権限を持つカスタムロールを作成するか、このカスタムロールを任意のタスク所有者ロールに付与して、自身のタスクの変更を許可できます。タスク所有者ロールがタスクを実行する機能を削除するには、このカスタムロールをタスク所有者ロールから取り消します。

たとえば、カスタムロール名 taskadmin を作成し、そのロールに EXECUTE TASK 権限を付与します。 myrole という名前のタスク所有者ロールに taskadmin ロールを割り当てます。

USE ROLE securityadmin;

CREATE ROLE taskadmin;

from snowflake.core.role import Role

root.session.use_role("securityadmin")

root.roles.create(Role(name="taskadmin"))

新しいロールにアカウントレベルの権限を付与する前に、アクティブなロールをACCOUNTADMINに設定します。

USE ROLE accountadmin;

GRANT EXECUTE TASK, EXECUTE MANAGED TASK ON ACCOUNT TO ROLE taskadmin;

root.session.use_role("accountadmin")

root.roles['taskadmin'].grant_privileges(
    privileges=["EXECUTE TASK", "EXECUTE MANAGED TASK"], securable_type="account"
)

このロールが他のロールにロールを付与できることを示すために、アクティブなロールをSECURITYADMINに設定します。

USE ROLE securityadmin;

GRANT ROLE taskadmin TO ROLE myrole;

from snowflake.core.role import Securable

root.session.use_role("securityadmin")

root.roles['myrole'].grant_role(role_type="ROLE", role=Securable(name='taskadmin'))

カスタムロールとロール階層の作成の詳細については、 アクセス制御の構成 をご参照ください。