任务简介¶

Serverless Task¶

通过任务的无服务器计算模型，您可以依靠由 Snowflake 管理的计算资源，而非由用户管理的虚拟仓库。Snowflake 会根据每个工作负载的需要自动调整无服务器计算资源的大小。Snowflake 对同一项任务最近一次运行的统计数据执行动态分析，并根据结果确定给定运行的无服务器计算资源的理想大小。Serverless Task 的最大计算大小相当于 XXLARGE 用户管理的虚拟仓库。

要使用无服务器计算模型，请在使用 CREATE TASK 创建任务时省略 WAREHOUSE 参数。请注意，执行 CREATE TASK 命令的角色必须具有全局 EXECUTE MANAGED TASK 权限。有关任务的访问控制要求的更多信息，请参阅 任务安全性。

Serverless Task 的运行计费方式与依赖虚拟仓库提供计算资源的任务（使用标准的 Credit 消耗模式）有所不同。有关更多信息，请参阅 任务成本。

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

• SERVERLESS_TASK_MAX_STATEMENT_SIZE：在 Serverless Task 上运行的仓库的最大大小，用以防止产生意外成本。

• SERVERLESS_TASK_MIN_STATEMENT_SIZE：Serverless Task 上可预测性能的仓库的最小大小。

• TARGET_COMPLETION_INTERVAL：期望的任务完成时间。Snowflake 会自动调整无服务器计算资源的大小，以在目标完成间隔内指定的时间内完成任务。如果未为计划任务设置此值，Snowflake 则会调整无服务器计算资源的大小，以在下一个计划执行时间之前完成。

  • 如果一系列任务执行在 TARGET_COMPLETION_INTERVAL 的指定值或更小的倍数内完成，则 Snowflake 会将无服务器计算缩减到下一个大小，以便后续任务执行在指定的 TARGET_COMPLETION_INTERVAL 内完成。

  • 如果一系列任务的执行时间超出 TARGET_COMPLETION_INTERVAL 的倍数，则 Snowflake 会将无服务器计算扩展到下一个大小，以便后续任务执行在指定的 TARGET_COMPLETION_INTERVAL 内完成。

指定这三个设置时，优先级如下：

• SERVERLESS_TASK_MAX_STATEMENT_SIZE

• SERVERLESS_TASK_MIN_STATEMENT_SIZE

• TARGET_COMPLETION_INTERVAL

以下是使用这些参数控制 Serverless Task 的一些示例。

示例 1：创建一个每小时运行一次的 Serverless Task，且目标完成间隔为 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：创建一个每小时运行一次的 Serverless Task，且目标完成时间为 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 会自动调整无服务器计算的大小，以便任务执行在指定的 TARGET_COMPLETION_INTERVAL 内完成，直到达到 SERVERLESS_TASK_MAX_STATEMENT_SIZE。

示例 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;

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

示例 4：创建一个每天计划一次且无目标完成间隔的 Serverless Task：

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

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

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

由用户管理的任务¶

您也可以在创建任务时指定一个现有虚拟仓库来管理单项任务的计算资源。若要使用此选项，需要选择一个大小适合于任务执行的 SQL 操作的仓库。

选择仓库大小¶

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

要分析任务的平均运行时间，请查询 TASK_HISTORY 账户使用情况视图。任务的计划时间和完成时间之间的平均差即为任务的预期平均运行时间。该差异包括当其他进程使用仓库中的计算资源时任务排队的时间。

对于任务图，在前置任务完成运行和任何子任务启动之后会有短暂的延迟。选择一个足够大的仓库来容纳同时运行的多个子任务。

下图显示了一个 1 分钟的窗口，其中一个任务排队 20 秒，然后运行 40 秒。这意味着在任务计划后的前 20 秒内，其他进程正在使用仓库资源。

下图显示了一个每次运行平均需要 5 分钟才能完成的任务图。图中显示了 2 次任务图运行完成所需的时间段。此时间段的计算起止时间为从计划启动根任务的时间，直到最后一个子任务完成运行。

在此示例中，任务图所运行的仓库与其他并发操作共享。当任务图中的每项任务运行完毕之时，以及下一任务开始运行之前，这些并发操作会消耗所有可用资源。因此，每项任务的时间段均包含一定的排队时间，用于等待其他操作完成并释放计算资源。

有关选择计算模型的建议¶

下表描述了有助于决定何时使用 Serverless Task 与由用户管理的任务的各种因素：

Serverless Task 运行的最大大小等于 XXLARGE 仓库的大小。如果一个任务工作负载需要更大的仓库，则创建一个具有所需大小仓库的由用户管理的任务。

任务计划¶

任务一般按计划运行。可在创建任务时使用 CREATE TASK 或稍后使用 ALTER TASK 来定义计划。

独立任务或任务图中的根任务通常按计划运行。可在创建任务时使用 CREATE TASK 或稍后使用 ALTER TASK 来定义计划。

Snowflake 确保一次只执行一个具有计划的任务实例。如在下一个计划内的执行时间到来时，任务仍在运行，则会跳过该计划内的时间。

Snowflake 会自动调整和缩放 Serverless Task 的计算资源大小。对于由用户管理的任务，选择合适的仓库大小，以便任务在计划内完成其工作负载。有关信息，请参阅 选择仓库大小。

触发任务¶

您可以使用触发任务，仅在定义的流具有新数据时才运行。这消除了在新数据的可用性不可预测时需要频繁轮询源的问题。它还减少了延迟，因为数据是立即处理的。

在定义的流具有数据并触发任务运行之前，触发任务不会使用计算资源。

以下是触发任务的运行条件：

• 当关联流跟踪的表中的数据发生更改时。

• 当任务首次恢复时，使用流中已有的任何数据。

• 触发任务每 12 小时自动运行一次运行状况检查，以防止流 过时。如果流中没有数据，Snowflake 将跳过运行而不使用计算资源。

CREATE TASK triggeredTask  WAREHOUSE = my_warehouse
  WHEN system$stream_has_data('my_stream')
  AS
    INSERT INTO my_downstream_table
    SELECT * FROM my_stream;

ALTER TASK triggeredTask RESUME;

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

手动执行任务¶

EXECUTE TASK 命令手动触发任务的单次运行。此 SQL 命令非常有用，可在允许新任务或修改的任务在生产环境中执行 SQL 代码之前测试它们。

可直接在脚本或存储过程中调用此 SQL 命令。此外，此命令还支持在外部数据管道中集成任务。任何可以通过身份验证进入您 Snowflake 账户并授权 SQL 操作的第三方服务都可以执行 EXECUTE TASK 命令来运行任务。

任务运行的版本控制¶

首次恢复或手动执行独立任务时，系统会设置任务的初始版本。独立任务使用此版本运行。暂停和修改任务后，恢复或手动执行独立任务时会设置新版本。

当任务暂停时，任务的所有未来计划运行都将被取消；但是，当前运行的任务将使用当前版本继续运行。

例如，假设任务已暂停，但任务的计划运行已开始。任务的所有者在任务仍在运行期间修改任务调用的 SQL 代码。任务使用任务开始运行时的当前版本运行并执行其定义中的 SQL 代码。恢复或手动执行任务时，将会为任务设置一个新版本。这个新版本包括对任务的修改。

要检索任务版本的历史记录，请查询 TASK_VERSIONS Account Usage 视图 （在 SNOWFLAKE 共享数据库中）。

在运行失败后自动暂停任务¶

（可选）在指定次数的连续运行失败或超时后自动暂停任务。此功能可暂停消耗 Snowflake credit 但无法运行至完成的任务，从而降低相关费用。

设置任务的 SUSPEND_TASK_AFTER_NUM_FAILURES = num 参数。当参数设置为大于 0 的值时，在超过指定的任务运行连续失败次数或超时后，任务将自动暂停。

可在创建任务时使用 CREATE TASK 或稍后使用 ALTER TASK 设置此参数。也可在 Snowsight 中更改此值。

还可以在账户、数据库或架构级别设置 SUSPEND_TASK_AFTER_NUM_FAILURES 参数。此设置适用于修改对象中包含的所有任务。请注意，在较低级别显式设置的参数将替换在较高级别设置的参数值。

自动重试失败的任务运行¶

如果任何任务在 FAILED 状态下完成，Snowflake 可以自动重试该任务。默认情况下禁用自动任务重试。要启用此功能，请将 TASK_AUTO_RETRY_ATTEMPTS 设置为大于 0 的值。

使用错误通知的任务会发送有关每次失败的重试尝试的通知。有关更多信息，请参阅 配置发送错误通知的任务。

如果您在账户、数据库或架构级别设置 TASK_AUTO_RETRY_ATTEMPTS 参数值，相关更改将在修改过的对象中的任务下次计划运行时应用到这些任务。

访问控制权限¶

创建自定义角色来管理任务权限¶

使用自定义角色，您可以轻松管理授予 Snowflake 中每个账户或角色的权限。要使用自定义角色更改所有账户或角色的权限，请更新自定义角色。或者，通过移除自定义角色来撤销权限。

USE SYSADMIN;

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

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE warehouse_task_creation;

GRANT USAGE
  ON WAREHOUSE warehouse1
  TO ROLE warehouse_task_creation;

USE SYSADMIN;

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

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE serverless_task_creation;

GRANT EXECUTE MANAGED TASK ON ACCOUNT
  TO ROLE serverless_task_creation;

USE ROLE securityadmin;

CREATE ROLE taskadmin;

USE ROLE accountadmin;

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

USE ROLE securityadmin;

GRANT ROLE taskadmin TO ROLE myrole;

删除任务所有者角色¶

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

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

系统服务任务执行¶

虽然 Snowflake 可以以任务所有者的权限运行任务，但任务运行与用户无关。实际上，每次运行都是由系统服务执行的。任务与特定用户是分离的，以避免用户被删除、因身份验证问题而被锁定或角色被移除时可能出现的复杂情况。

由于任务运行与用户分离，任务运行的查询历史记录与系统服务相关联。因此，该服务没有用户凭据，并且没有个人可冒充其身份。系统服务的活动仅限于您的账户。该服务内置了与其他操作相同的加密保护和其他安全协议。