任务简介¶

限制¶

• Serverless Task 的最大计算大小相当于 XXLARGE 虚拟仓库。

使用无服务器计算模型创建任务¶

Use CREATE TASK to define the task. Don't include the WAREHOUSE parameter.

The role that runs the task must have the global EXECUTE MANAGED TASK privilege. For more information, see 任务安全性.

The following example creates a task that runs every hour.

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),
        ),
    )

Cost and performance: Warehouse sizes¶

为确保 Serverless Task 高效运行，您可通过设置以下参数来指定最小和最大 仓库规模：

• SERVERLESS_TASK_MIN_STATEMENT_SIZE: the minimum warehouse size for predictable performance (default: XSMALL).

• SERVERLESS_TASK_MAX_STATEMENT_SIZE: the maximum warehouse size to prevent unexpected costs (default: XXLARGE).

After a task completes, Snowflake reviews the performance and adjusts compute resources for future runs within these limits.

以下示例展示了一个每 30 秒运行的任务，其最小仓库规模为 SMALL，最大仓库规模为 LARGE。

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",
        ),
    )

目标完成间隔¶

您可以为 Serverless Task 设置更早的完成目标。无服务器触发任务 必须设置目标完成间隔。

设置后，Snowflake 将估算并扩展资源以在目标完成间隔内完成任务。当任务已达到最大仓库规模且运行时间过长时，目标完成间隔将被忽略。

以下示例中，任务每天午夜运行，目标在凌晨 2 点前完成。开始时间和时区通过 USING CRON 定义。如果任务达到最大仓库规模，可能运行长达三小时才会最终触发超时。

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,
    ),
)

Choose a warehouse¶

When choosing a warehouse, consider the following:

• 查阅 仓库注意事项 中的最佳实践。

• 根据仓库规模和群集配置，分析使用不同仓库时的平均任务运行时间。有关更多信息，请参阅 任务持续时间。

• 如果仓库由多个进程共享，需考虑任务对其他工作负载的影响。

Create a task using the user-managed compute model¶

Use CREATE TASK, and include the WAREHOUSE parameter.

The role that runs the task must have the global EXECUTE MANAGED TASK privilege. For more information, see 任务安全性.

The following example creates a task that runs every hour.

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

创建任务¶

要创建任务，角色必须至少具有以下权限：

运行任务¶

创建任务后，任务所有者必须具有以下权限才能运行任务：

此外，该角色必须具有运行任务运行的 SQL 语句所需的权限。

查看任务历史记录¶

要查看任务，您必须具有以下一个或多个权限：

• 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 的角色的示例；创建一个名为 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 权限。将 taskadmin 角色分配给名为 myrole 的任务所有者角色：

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 权限，且该指定用户必须被授予任务的所属角色。

When the task runs, the primary role of the task session will be the owner role of the task, and the user’s default secondary roles will be activated. Users will be able to switch primary roles with the USE ROLE command and adjust the secondary roles in the task session with the USE SECONDARY ROLES command.

使用服务用户和角色共享任务¶

对于生产环境，我们建议您创建一个单独的服务用户来代表您的团队或业务流程。与以现有服务用户或个人用户身份运行的方式相比，此最佳实践有助于提升工作流的安全性：

• 当任务以专用服务用户身份运行时，它只能获得预期权限的访问权限。反之，若用户冒充其他用户，则会获得与该用户关联的所有权限，其中可能包含非预期的权限，包括在创建和恢复任务后授予的用户权限。

• 若任务以用户身份运行，当该人员离开部门或组织时，任务可能会被中断。

示例：设置服务用户和团队角色¶

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. 查看日志。

   The SHOW GRANTS TO ROLE command would show that Jane granted the role to Billy. The QUERY_HISTORY view would then show that Billy modified the task. Future task runs would still appear as run by Jane.

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

   Copy