任务简介¶

Serverless Task¶

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

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

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

由用户管理的任务¶

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

选择仓库大小¶

如果您选择使用现有仓库为单项任务提供计算资源，建议您遵循 仓库注意事项 中介绍的最佳实践。建议根据仓库大小和聚类情况，分析使用特定仓库的单项任务或 :ref:` 任务图 <label-task_dag>` 的平均运行时间，以及仓库是由多个进程共享，还是专用于运行该单一任务或任务图。

查询 TASK_HISTORY Account Usage 视图 （在 SNOWFLAKE 共享数据库中）。任务的计划时间和完成时间之间的平均差即为任务的预期平均运行时间，包括任务排队的任何时间段。在当前有其他进程在使用仓库中的所有计算资源时，任务将会排队。

除非可以优化为任务定义的 SQL 语句（通过重写语句或使用存储过程），否则这将是任务或任务图的预期平均运行时间。根据分析结果选择合适的仓库大小，以确保任务或任务图在此时间段内完成运行。

下图显示了 1 分钟的时间段，在此时间段内，单项任务排队 20 秒，然后运行 40 秒。

下图显示了每次运行平均需要 5 分钟才能完成的一个任务图。er图中显示了两次任务图运行完成所需的时间段。此窗口的计算方式是从根任务计划启动的时间，到任务图中最后一个子任务完成运行的时间。在此示例中，任务图与其他并发操作共享，当任务图中的 3 项任务中的每一项都在运行时，这些并发操作排队。当任务图中的每项任务运行完毕之时，以及下一项任务开始运行之前，这些并发操作会消耗所有可用资源。因此，每项任务的时间段均包含一定的排队时间，用于等待其他操作完成并交出计算资源。

请注意，即使任务图基于专用仓库运行，在前置任务运行完毕、任何子任务执行之后，预计也会出现短暂的延迟；但不会出现与其他操作一起排队等候共享资源的情况。您选择的仓库应该足够大，可以容纳由前置任务同时触发的多个子任务。

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

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

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

任务计划与夏令时¶

任务定义中的 cron 表达式支持指定时区。计划任务根据以给定时区的本地时间指定的 cron 表达式运行。在为认可夏令时的时区计划任务时，应该特别小心。在从标准时间过渡到夏令时（或反之）的特定时间段内计划的任务可能会出现意外行为。

例如：

• 在秋季从夏令时改为标准时间期间，计划在 America/Los_Angeles 时区（即 0 1 * * * America/Los_Angeles）的 1 AM 开始的任务将运行 两次：一次在 1 AM，另一次在 1:59:59 AM 切换到当地时间 1:00:00 AM 时运行。也就是说，在当地时间为 1 AM 时，有两个时间点。

• 在春季从标准时间改为夏令时期间，计划在 America/Los_Angeles 时区（即 0 2 * * * America/Los_Angeles）的 2 AM 开始的任务 根本不会运行，因为当地时间从 1:59:59 AM 切换到 3:00:00 AM。也就是说，在当天，当地时间没有 2 AM 的时间点。

为避免因夏令时而意外执行任务， 请使用以下方法之一：

• 请勿将任务安排在 1 AM 至 3 AM 之间的特定时间运行（每天或每周的七天，含周日）， 或

• 每年两次，手动调整在这些时间计划的任务的 cron 表达式，以补偿夏令时导致的时间变化， 或

• 使用不适用于夏令时的时间格式，例如 UTC。

任务图所有权¶

任务图中的所有任务必须具有相同的任务所有者（即必须仅有一个角色具有所有任务的 OWNERSHIP 权限），并且存储在同一数据库和架构中。

如果转移任务所有权，则会切断该任务与任何前置任务和子任务之间的依赖关系。有关更多信息，请参阅 切断前置任务与子任务之间的关联 （本主题内容）。

当任务图中 所有 任务的所有权通过以下任何一种活动同时转移时，任务图中所有任务之间的关系将得到保留：

• 包含任务图的所有任务的当前所有者将被删除（使用 DROP ROLE）。被删除的角色所拥有的对象的所有权将转移给执行 DROP ROLE 命令的角色。

• 构成任务图的所有任务的所有权将显式转移给另一个角色（例如，通过对架构中的所有任务执行 GRANT OWNERSHIP）。

运行任务图中的任务¶

一个任务图的运行是由它定义的根任务的运行来启动的。根任务的成功运行会触发子任务的级联运行，因为子任务的前一项任务已经完成。根任务可通过以下方式运行：

• 任务计划 – 通常任务图是基于 CRON 或时间间隔的计划运行的。

• ALTER TASK – 您可以使用 ALTER TASK [ IF EXISTS ] <name> RESUME 来运行基于其现有计划的任务图。首次创建时，必须恢复所有任务。

• EXECUTE TASK – 您可以使用 EXECUTE TASK <name> 创建任务图的一次性运行。

重叠任务图运行¶

默认情况下，Snowflake 确保一次只允许运行一项特定任务图的一个实例。只有在该任务图中的所有任务都运行完毕后，才会安排根任务的下一次运行。这意味着，如果运行任务图中所有任务所需的累积时间超过了根任务定义中设置的明确计划时间，则至少会跳过任务图的一次运行。该行为由根任务上的 ALLOW_OVERLAPPING_EXECUTION 参数控制；默认值为 FALSE。将参数值设置为 TRUE，这将允许任务图重叠运行 。

此外，只有在子任务的:emph:`所有`前置任务均成功完成自己的运行后，子任务才能开始运行。如一项任务会执行耗时的 SQL 操作，则会造成任何将该任务标识为前置任务的子任务的启动发生延迟。

在以下示例中，任务图计划在上一次运行尚未完成时开始运行。重叠期（或称为并发时间）以红色标识。该图还确定了每项任务在由用户管理的仓库中运行之前，需要排队的排队的时间跨度。请注意，如果使用无服务器计算资源，那么就没有排队期：

在重叠运行任务图执行的读/写 SQL 操作不会产生错误或重复的数据时，重叠运行是可以容忍的（甚至是可取的）。但是，对于其他任务图，任务所有者（对任务图中所有任务具有 OWNERSHIP 权限的角色）应为根任务设置适当的计划，并选择适当的仓库大小（或使用无服务器计算资源），以确保在下次计划运行根任务之前完成任务图的一个实例。

为了更好地将任务图与根任务中定义的计划保持一致，请执行以下操作：

1. 如可行，延长根任务运行之间的计划时间。

2. 考虑修改计算密集型任务，以使用无服务器计算资源。如果任务依赖于由用户管理的计算资源，请增加运行任务图中大型或复杂 SQL 语句或存储过程的仓库的大小。

3. 分析每项任务执行的 SQL 语句或存储过程。确定是否可以重写代码，以利用并行处理。

如果以上解决方案都没有帮助，请考虑是否需要对根任务设置 ALLOW_OVERLAPPING_EXECUTION = TRUE，以允许并行运行任务图。可在创建任务时（使用 CREATE TASK）或稍后使用 ALTER TASK 或 Snowsight）来定义此参数。

查看任务图中的依赖任务¶

要查看根任务的直接子任务或者任务图中的所有任务，请执行以下操作：

SQL:

查询 TASK_DEPENDENTS 表函数（在 Snowflake Information Schema 中）。请注意，要在任务图中检索 所有 任务，请在调用该函数时输入根任务。如果输入子任务，该函数将返回指定任务的子任务（以及这些子任务的子任务，依次类推）。

Snowsight

要在 Snowsight 中查看任务图，请参阅 查看和管理任务图。

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

（可选）在任务运行连续失败指定次数或超时后自动暂停任务图。

在任务图中设置根任务的 SUSPEND_TASK_AFTER_NUM_FAILURES = num 参数。当参数设置为大于 0 的值时，任务图中的 任何 子任务连续失败或超时指定次数后，根任务将自动暂停。失败或超时的子任务不会暂停。

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

指定任务图自动重试的次数。如果任何任务图在 FAILED 状态下完成，Snowflake 可以自动从失败的图中的最后一个任务重试任务图。

任务图自动重试功能默认处于禁用状态。要启用此功能，请将 TASK_AUTO_RETRY_ATTEMPTS 设置为大于 0 的值。

切断前置任务与子任务之间的关联¶

任务图中任务之间的依赖关系可以通过以下操作断开：

• ALTER TASK ...REMOVE AFTER 和 ALTER TASK ...UNSET FINALIZE 解除目标任务与指定的前置任务或最终根任务之间的关联。

• DROP TASK 和 GRANT OWNERSHIP 会切断目标任务的所有关联。例如，根任务 A 有子任务 B，而任务 B 有子任务 C。如果删除任务 B，则任务 A 和 B 之间的关联将被解除，任务 B 和 C 之间的关联也将被解除。

如果上述操作的任意组合切断了子任务与 所有 前置任务之间的关系，则其前一个子任务将变为独立任务或根任务，具体取决于是否有其他任务将该任务标识为其前置任务。

终结器任务¶

终结器任务在任务图中的所有其他任务运行完成之后运行。您可以定义终结器任务的 SQL，来处理任务图所使用的通知以及资源的释放和清理。例如，如果任务图运行使用中间表来跟踪需要处理的数据，但在尚未消耗表行的情况下失败，则下一次运行将遇到重复的行并重新处理数据，从而导致执行时间延长或浪费计算资源。终结器任务可以按需删除行或截断表，从而解决此问题。

终结器任务的工作方式与任务图中的其他任何任务很相似，但有以下区别：

• 终结器任务始终与根任务关联。每个根任务只能有一个终结器任务，一个终结器任务只能与一个根任务相关联。

• 当任务图中的任何任务开始运行时，将安排终结器任务。终结器任务只有在任务图中的所有任务运行完成后才运行。如果跳过某个任务图，则终结器任务不会运行。

• 终结器任务不能有任何子任务。任何尝试将终结器任务设为前置任务的命令都将失败。

• 终结器任务的创建必须包含 FINALIZE 关键字，该关键字与 SCHEDULE 和 AFTER 关键字均不兼容。

要创建终结器任务，请使用 FINALIZE 关键字创建任务，并设置与根任务的关系：

CREATE TASK <TASK_NAME> ...
... FINALIZE = <ROOT_TASK_NAME>

有关更多信息，请参阅 CREATE TASK。

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

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

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

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

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

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

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

当您在账户、数据库或架构级别设置 TASK_AUTO_RETRY_ATTEMPTS 参数值时，系统将在修改对象包含的任务下次计划运行期间为其应用更改。

访问控制权限¶

创建任务管理员角色¶

为简化使用，我们建议创建自定义角色（例如 taskadmin）并为该角色分配 EXECUTE TASK 权限。然后，任何可以授予权限的角色（例如 SECURITYADMIN 或任何具有 MANAGE GRANTS 权限的角色）均可将此自定义角色授予任何任务所有者角色，以允许其修改自己的任务。要移除任务所有者角色执行任务的能力，只需从任务所有者角色撤消该自定义角色即可。请注意，如果选择不创建此自定义角色，账户管理员必须撤消任务所有者角色的 EXECUTE TASK 权限。

例如，创建名为 taskadmin 的自定义角色，并授予该角色 EXECUTE TASK 权限。将 taskadmin 角色分配给名为 myrole 的任务所有者角色：

USE ROLE securityadmin;

CREATE ROLE taskadmin;

-- set the active role to ACCOUNTADMIN before granting the account-level privileges to the new role
USE ROLE accountadmin;

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

-- set the active role to SECURITYADMIN to show that this role can grant a role to another role
USE ROLE securityadmin;

GRANT ROLE taskadmin TO ROLE myrole;

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

删除任务所有者角色¶

删除给定任务的所有者角色（即具有该任务的 OWNERSHIP 权限的角色）时，该任务将被删除所有者角色的角色“收回”。这可确保所有权转移到更接近角色层次结构根节点的角色。在任务被收回时，它会自动暂停，即当前进行中的所有执行都将完成处理，但在新所有者显式恢复任务之前，不会计划新的执行。采取这种处理方式的原因在于，在移除角色时，防止拥有特定角色访问权限的用户留下突然以更高权限执行的任务。

如果在任务运行过程中，用于执行该任务的角色被删除，则该任务将在已删除的角色下完成处理。