任务简介¶

限制¶

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

• 总任务时间可能包括任务开始前的延迟。有关更多信息，请参阅 任务持续时间。

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

如果使用 CREATE TASK 或 ALTER TASK，请省略 WAREHOUSE 参数。

执行任务的角色必须具有全局 EXECUTE MANAGED TASK 权限。有关任务的访问控制要求的更多信息，请参阅 任务安全性。

您可以通过设置以下参数来控制 Serverless Task 的成本和性能：

• SERVERLESS_TASK_MAX_STATEMENT_SIZE：仓库的最大大小，以防止出现意外费用。

• SERVERLESS_TASK_MIN_STATEMENT_SIZE：仓库的最小大小，以确保性能可预测。

• TARGET_COMPLETION_INTERVAL：任务应执行的时间窗口。

Snowflake 如何估算无服务器计算资源¶

Snowflake 会根据目标时间范围以及之前任务运行的性能自动估算完成任务所需的计算资源。

您可以使用 TARGET_COMPLETION_INTERVAL 设置目标时间范围。如果未设置此值，Snowflake 会调整无服务器计算资源的大小，以在下一个计划的执行时间之前完成。

任务完成后，Snowflake 会按以下方式估算所需的计算资源：

• 如果任务完成得过快（在比目标时间范围少一个时间因子的时间内完成），Snowflake 会在后续运行中将资源规模缩小一个 仓库大小，直至 SERVERLESS_TASK_MIN_STATEMENT_SIZE。

• 如果任务完成得过慢（在比目标时间框架多一个时间因子的时间内完成），Snowflake 会在后续运行中将资源规模扩大一个 仓库大小。当达到 SERVERLESS_TASK_MAX_STATEMENT_SIZE 时，任务会继续（可能超过目标时间），直到任务完成或超时为止。

示例¶

示例 1：创建每小时运行一次的 Serverless Task 任务。Snowflake 分配无服务器计算资源，估计这些资源将在计划时间内完成任务。

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

示例 2：创建每天运行的 Serverless Task，从午夜开始运行 2 小时。时间表（使用 CRON）定义任务的开始时间，包括时区。目标完成间隔定义任务应何时完成。Snowflake 估计并分配无服务器计算，以便任务在计划时间内完成。

CREATE TASK SCHEDULED_T2
  SCHEDULE='USING CRON 0 * * * * America/Los_Angeles'
  TARGET_COMPLETION_INTERVAL='120 MINUTE'
  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=Cron("0 * * * *", "America/Los_Angeles"),
        target_completion_interval=timedelta(minutes=120),
        serverless_task_max_statement_size="LARGE",
    ),
)

示例 3：创建一个每天计划一次的 Serverless Task，并设置目标完成间隔以及最小和最大仓库大小的范围：

CREATE TASK SCHEDULED_T3
  SCHEDULE='USING CRON 0 0 * * * UTC'
  TARGET_COMPLETION_INTERVAL='180 M'
  SERVERLESS_TASK_MIN_STATEMENT_SIZE='MEDIUM'
  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_T3",
        definition="SELECT 1",
        schedule=Cron("0 0 * * *", "UTC"),
        target_completion_interval=timedelta(minutes=180),
        serverless_task_min_statement_size="MEDIUM",
        serverless_task_max_statement_size="LARGE",
    ),
)

通过此配置，Serverless Task 每天午夜至少在 TARGET_COMPLETION_INTERVAL 为 3 小时的中型仓库上运行一次。Snowflake 会自动调整无服务器计算的大小，以便任务执行在指定的 TARGET_COMPLETION_INTERVAL 内完成，直到达到 SERVERLESS_TASK_MAX_STATEMENT_SIZE。

示例 4：创建计划每 10 秒运行一次的 Serverless Task，设置目标完成间隔：

CREATE TASK SCHEDULED_T4
  SCHEDULE='10 SECONDS'
  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_T4",
        definition="SELECT 1",
        schedule=timedelta(seconds=10),
        serverless_task_max_statement_size="LARGE",
    ),
)

使用此配置，Serverless Task 每 10 秒运行一次。如果一系列任务执行持续时间未在下一个计划时间之前完成，Snowflake 会自动调整无服务器计算的大小，以便任务执行在指定的 SCHEDULE 内完成，直到达到 SERVERLESS_TASK_MAX_STATEMENT_SIZE。

有关参数和语法的更多信息，请参阅 CREATE TASK 和 ALTER TASK。

选择仓库大小¶

如果选择使用现有仓库为单项任务提供计算资源，请遵循 仓库注意事项 中描述的最佳实践。要了解任务的计算需求，可根据仓库大小和群集情况，使用不同的仓库分析单项任务或 任务图 的平均运行时间。还应考虑仓库是否由多个进程共享。有关更多信息，请参阅 任务持续时间。

创建任务¶

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

运行任务¶

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

此外，该角色必须具有运行任务运行的 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'))

有关创建自定义角色和角色层次结构的更多信息，请参阅 配置访问控制。

删除任务所有者角色¶

当删除任务的所有者角色时，该任务会将所有权转移给删除所有者角色的那个角色。当任务转移所有权时，它会自动暂停，并且在新的所有者恢复任务之前不会计划新的任务运行。

如果在任务运行时删除角色，则任务运行将在被删除的角色下完成处理。

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

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

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

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

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

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