タスクの紹介¶

制限事項¶

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

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

タスクを定義するには CREATE TASK を使用します。WAREHOUSE パラメーターを含めないでください。

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

次の例では、1時間ごとに実行されるタスクを作成します。

CREATE TASK SCHEDULED_T1
  SCHEDULE='60 MINUTES'
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T1",
        definition="SELECT 1",
        schedule=timedelta(minutes=60),
        ),
    )

コストとパフォーマンス: ウェアハウスのサイズ¶

サーバーレスタスクを効率的に実行するために、次のパラメーターを設定して、最小および最大の :ref:` ウェアハウスサイズ <label-warehouse_size>` を設定できます。

• SERVERLESS_TASK_MIN_STATEMENT_SIZE: 予測可能なパフォーマンスのための最小ウェアハウスサイズ（デフォルト: XSMALL）。

• SERVERLESS_TASK_MAX_STATEMENT_SIZE: 想定外のコストを防ぐための最大ウェアハウスサイズ（デフォルト: XXLARGE）。

タスクが完了すると、Snowflakeはパフォーマンスを確認し、これらの制限内で今後の実行のためにコンピューティングリソースを調整します。

次の例は、最小ウェアハウスサイズが SMALL、最大ウェアハウスサイズが LARGE で、30秒ごとに実行されるタスクを示しています。

CREATE TASK SCHEDULED_T2
  SCHEDULE='30 SECONDS'
  SERVERLESS_TASK_MIN_STATEMENT_SIZE='SMALL'
  SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T2",
        definition="SELECT 1",
        schedule=timedelta(seconds=30),
        serverless_task_min_statement_size="SMALL",
        serverless_task_max_statement_size="LARGE",
        ),
    )

ターゲット補完間隔¶

サーバーレスタスクの完了目標を早期に設定できます。サーバーレストリガータスク には、ターゲット完了間隔が必要です

設定すると、Snowflakeはリソースを推定し、ターゲット完了間隔内に完了するようにスケーリングします。タスクがすでに最大ウェアハウスサイズに達していて、実行時間が長すぎる場合、ターゲット完了間隔は無視されます。

以下の例では、タスクは毎日午前0時に実行され、午前2時までに完了することを目標としています。開始時間とタイムゾーンは USING CRON によって定義されます。タスクが最大のウェアハウスサイズに達した場合、最終的にタイムアウトをトリガーするまでに最大3時間実行される場合があります。

CREATE TASK SCHEDULED_T3
  SCHEDULE='USING CRON 0 * * * * America/Los_Angeles'
  TARGET_COMPLETION_INTERVAL='120 MINUTE'
  SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
  USER_TASK_TIMEOUT_MS = 10800000         -- (3 hours)
  SUSPEND_TASK_AFTER_NUM_FAILURES = 3
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T3",
        definition="SELECT 1",
        schedule=Cron("0 * * * *", "America/Los_Angeles"),
        target_completion_interval=timedelta(minutes=120),
        serverless_task_max_statement_size="LARGE",
        user_task_timeout_ms=10800000,  # (3 hours)
        suspend_task_after_num_failures=3,
    ),
)

ウェアハウスを選択¶

ウェアハウスを選択するときは、次の点を考慮してください。

• ウェアハウスに関する考慮事項 のベストプラクティスを確認してください。

• ウェアハウスのサイズとクラスタリングに基づいて、異なるウェアハウスを使用してタスクの平均実行時間を分析してください。詳細については、 タスク期間 をご参照ください。

• ウェアハウスが複数のプロセスで共有されている場合は、タスクが他のワークロードに与える影響を考慮してください。

ユーザー管理のコンピューティングモデルを使ったタスクの作成¶

CREATE TASK を使用し、WAREHOUSE パラメーターを含めます。

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

次の例では、1時間ごとに実行されるタスクを作成します。

CREATE TASK SCHEDULED_T1
  WAREHOUSE='COMPUTE_WH'
  SCHEDULE='60 MINUTES'
  AS SELECT 1;

タスクの作成¶

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

タスクの実行¶

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

またロールは、タスクによって実行される 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'))

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

タスク所有者ロールのドロップ¶

タスクの所有者ロールをドロップすると、タスクは所有者ロールをドロップしたロールに所有権を移します。タスクの所有権が移ると、タスクは自動的に一時停止され、新しい所有者がタスクを再開するまで新しいタスク実行はスケジュールされません。

タスクの実行中にロールを削除すると、タスクの実行はドロップされたロールの下で完了します。

アクセス制御¶

タスクの所有者ロールには、EXECUTE AS USER により指定されたユーザーに対する IMPERSONATE 権限が付与されている必要があり、指定されたユーザーにはタスクの所有者ロールが付与されている必要があります。

タスクが実行されると、タスクセッションのプライマリロールはタスクの所有者ロールになり、ユーザーのデフォルトのセカンダリロールがアクティブ化されます。ユーザーは、USE ROLE コマンドを使用してプライマリロールを切り替え、USE SECONDARY ROLES コマンドを使用してタスクセッション内のセカンダリロールを調整できるようになります。

サービスユーザーとロールを使用してタスクを共有する¶

実稼働環境の場合は、チームまたはビジネスプロセスを表す別個のサービスユーザーを作成することをお勧めします。既存のサービスユーザーまたは個人ユーザーとして実行する場合とは異なり、このベストプラクティスはワークフローのセキュリティ強化に役立ちます。

• タスクが専用サービスユーザーとして実行される場合、そのタスクは意図された権限のみにアクセスできます。ユーザーが他のユーザーになりすました場合、そのユーザーに関連付けられたすべての権限にアクセスできるようになります。これには、タスクの作成や再開後に付与されたユーザー権限など、意図しない権限が含まれる可能性があります。

• ユーザーとしてタスクを実行している場合、そのユーザーが部門や組織を離れると、タスクが中断される可能性があります。

例：サービスユーザーとチームロールの設定¶

1. 管理者ロールを使用して、タスクに使用するサービスユーザーを設定します。

   次の例では、task_user という名前のサービスユーザーを作成します。

   USE ROLE ACCOUNTADMIN;
   CREATE USER task_user;
   

   Copy

2. タスクロールを作成し、それをサービスユーザーに付与します。

   CREATE ROLE task_role;
   GRANT ROLE task_role to USER task_user;
   

   Copy

3. タスクロールがチームユーザーロールに代わってクエリを実行できるようにします。

   GRANT IMPERSONATE ON USER task_user TO ROLE task_role;
   

   Copy

4. タスクロールに適切な権限を付与します。

   USE ROLE ACCOUNTADMIN;
   
   -- Grant the team role the privileges to create tasks in a specific schema
   GRANT CREATE TASK
     ON SCHEMA schema1
     TO ROLE task_role;
   
   -- Grant the team role the privileges to use a specific warehouse
   GRANT USAGE
     ON WAREHOUSE warehouse1
     TO ROLE task_role;
   
   -- Grant the team role the privileges to run tasks on a serverless compute model
   GRANT EXECUTE MANAGED TASK ON ACCOUNT TO ROLE task_role;
   

   Copy

サービスユーザーに代わってタスクを実行する¶

チームロールがタスクの所有権を持つと、チームメンバーはタスクを変更し、サービスユーザーに代わってタスクを実行できます。

例：

USE ROLE task_owner;

CREATE TASK team_task
  SCHEDULE='12 HOURS'
  EXECUTE AS USER task_user
  AS SELECT 1;

前の例では、結果のログには task_user がタスクを変更したことが示されます。

（テスト専用）ユーザーが他のユーザーを直接偽装することを許可する¶

変更をテストまたはプロトタイプ化する場合、管理者はユーザーが他のユーザーを直接偽装することを許可できます。このシナリオはサポートされていますが、実稼働環境では推奨されません。

1. 偽装用のロールを設定します。

   USE ROLE ACCOUNTADMIN;
   CREATE ROLE janes_role;
   GRANT ROLE janes_role to USER jane;
   GRANT IMPERSONATE ON USER jane TO ROLE janes_role;
   

   Copy

2. 新しいロールを使用してタスクを作成します。

   USE ROLE janes_role;
   
   CREATE TASK janes_task
     SCHEDULE='60 M' AS SELECT 1;
   

   Copy

3. 別のユーザーにそのロールを付与します。

   次の例では、ユーザーJaneがユーザーBillyにアクセス権を付与します。

   --Logged in as Jane or account admin
   GRANT ROLE janes_role to USER billy;
   

   Copy

4. 他のユーザーがタスクを変更します。

   次の例では、ユーザーBillyがタスクを変更します。

   -- Logged in as billy
   USE ROLE janes_role;
   
   ALTER TASK janes_task
     SET EXECUTE AS USER jane;
   

   Copy

5. ログを確認します。

   SHOW GRANTS TO ROLE コマンドを実行するとJaneがBillyにロールを付与したことが表示されます。次に、QUERY_HISTORY ビューを確認すると、Billyがタスクを変更したことがわかります。今後そのタスクが実行された場合でも、実行者としては引き続きJaneとして表示されます。

   USE ROLE ACCOUNTADMIN;
   
   SHOW GRANTS TO ROLE janes_role;
   
   QUERY_HISTORY()
     WHERE QUERY_TEXT ILIKE '%janes_task%';
   

   Copy