Snowflake 任务

2025 年 7 月 29 日 | 阅读 18 分钟

引言

Snowflake 任务是基于云的数据仓库平台 Snowflake 的一个关键功能。它们使用户能够自动化和调度 SQL 语句，这对于高效管理数据工作流至关重要。通过利用 Snowflake 任务，组织可以确保他们的数据流程平稳一致地运行，而无需手动干预。

什么是 Snowflake 任务？

Snowflake 任务是自动调度器，可在预定义的时间间隔或响应特定触发器时执行 SQL 语句。它们允许用户定义 SQL 查询、存储过程或其他数据库命令，这些命令可以根据计划或在不同任务完成后自动执行。

Snowflake 任务包括：

自动化： 自动化常规的数据处理和维护任务，减少手动执行和监督的需求。
调度： 使用灵活的调度选项定义任务的运行时间和频率。
依赖管理： 通过将任务链接在一起创建复杂的工作流，其中一个任务可以在另一个任务完成后运行。

为什么要使用 Snowflake 任务？

效率： 自动化重复性任务可节省时间并降低人为错误的风险。可以安排数据转换、ETL 过程和常规维护等任务自动运行。
一致性： 计划任务可确保数据处理在规则的间隔或特定条件下发生，从而带来更可靠、更一致的数据管理实践。
可扩展性： 随着数据量和处理需求的增长，Snowflake 任务可以相应地扩展，处理增加的工作负载而无需额外的手动干预。
灵活性： Snowflake 任务可以配置为满足各种需求，从简单的定期数据加载到涉及多个依赖任务的复杂工作流。

Snowflake 任务如何工作

Snowflake 任务通过一个简单的执行流程运行：

定义： 用户通过指定要执行的 SQL 语句或存储过程，以及计划或触发条件来定义任务。
调度： 可以使用 CRON 表达式进行精确计时来安排任务，或者配置为基于其他任务的完成来运行。
执行： 当指定的或触发的条件满足时，Snowflake 会执行任务，运行定义的 SQL 语句或过程。
监控和日志记录： 执行详细信息，包括成功、失败和性能指标，都会被记录下来，并可供查看，以确保任务按预期运行。
完成： 执行完成后，任务可能会触发后续任务（如果设置了依赖项）或发送有关其状态的通知。

Snowflake 任务的关键特性

CRON 调度： 可以使用 CRON 表达式调度任务，从而对执行时间进行精细控制（例如，每天早上 6 点，每小时）。
任务依赖： 定义任务之间的关系，以便一个任务只能在另一个任务完成后开始。
重试机制： 为失败的任务配置重试逻辑，确保瞬时问题不会中断工作流。
资源管理： 指定用于任务执行的计算资源（仓库），以优化性能和成本。

任务创建工作流

在 Snowflake 中创建和管理任务涉及几个关键步骤，从定义任务到设置其计划和依赖项。此工作流可确保任务得到适当配置，以自动化 SQL 执行并有效地融入您的数据处理生态系统。

任务需求

在创建任务之前，了解其需求和目标至关重要：

目标： 任务的目的是什么？（例如，数据摄取、转换、维护）
SQL 语句： 任务将执行哪些 SQL 查询或存储过程？
计划： 任务应多久运行一次？（例如，每小时、每天、每周）
依赖项： 任务是否依赖于其他任务的完成？
资源分配： 任务将使用哪个 Snowflake 仓库？

创建任务

需求确定后，您就可以使用 CREATE TASK 命令创建任务。以下是详细步骤：

指定任务名称： 为任务选择一个描述性名称。
分配仓库： 指定任务将使用的计算仓库。
定义计划： 使用 CRON 语法或其他调度选项设置频率。
包含 SQL 语句： 编写任务将执行的 SQL 查询或调用存储过程。
添加注释： 可选地，添加注释来描述任务的目的。

示例

CREATE TASK daily_data_ingest
  WAREHOUSE = data_warehouse
  SCHEDULE = 'USING CRON 0 6 * * * UTC'
  COMMENT = 'Task to ingest daily data from external sources'
AS
  CALL ingest_data_procedure();

配置任务调度器

Snowflake 允许使用 CRON 表达式进行灵活调度，CRON 表达式定义了任务执行的确切时间和频率。如果可用，您也可以使用其他调度选项。

CRON 语法示例

0 6 * * * UTC：每天 UTC 时间早上 6 点运行
0 */2 * * * UTC：每 2 小时运行一次
0 0 1 * * UTC：每月 1 号午夜运行

设置计划

ALTER TASK daily_data_ingest
  SET SCHEDULE = 'USING CRON 0 6***UTC';

设置任务依赖项

如果您的任务需要在其他任务完成后运行，您可以定义这些条件。这可以保证任务按正确的顺序执行。

依赖任务示例

CREATE TASK final_processing_task
  AFTER data_ingest_task
  WAREHOUSE = processing_warehouse
AS
  INSERT INTO final_table
  SELECT * FROM intermediate_table;

在此示例中，final_processing_task 将仅在 data_ingest_task 成功完成后执行。

管理任务执行

创建任务后，您可能需要管理其执行：

暂停或恢复： 暂时停止或重新启动任务。
修改： 更改 SQL 语句、计划或依赖项。
删除： 当不再需要任务时将其删除。

暂停任务

ALTER TASK daily_data_ingest
  SUSPEND;

恢复任务

ALTER TASK daily_data_ingest
  RESUME;

修改任务计划

ALTER TASK daily_data_ingest
  SET SCHEDULE = 'USING CRON 0 7 * * * UTC';

删除任务

监控和故障排除任务

有效的监控可确保任务按预期运行：

检查任务历史： 查看执行历史以了解任务是否成功运行或遇到错误。
查看日志： 检查日志以获取有关任务执行、失败和性能问题的详细信息。
处理故障： 实现重试逻辑和通知来管理任务故障并从问题中恢复。

查询任务历史

SELECT *
FROM INFORMATION_SCHEMA.TASK_HISTORY
WHERE TASK_NAME = 'daily_data_ingest';

启用重试示例

ALTER TASK daily_data_ingest
  SET MAX_RETRIES = 3, RETRY_INTERVAL = '5 MINUTES';

文档记录和审查

文档有助于保持清晰和一致性：

记录任务目的： 清楚地描述每个任务的作用以及为何需要它。
审查任务配置： 定期审查任务配置，以确保它们满足当前需求和性能标准。

创建时添加注释

CREATE TASK data_cleaning_task
  WAREHOUSE = maintenance_warehouse
  SCHEDULE = 'USING CRON 0 2 * * * UTC'
  COMMENT = 'Cleans up old data from staging tables'
AS
  DELETE FROM staging_table WHERE created_at < CURRENT_DATE - INTERVAL '30 DAY';

触发式任务

Snowflake 中的触发式任务是一项强大的功能，它允许根据某些条件或事件自动执行 SQL 查询或存储过程。这些任务可以简化工作流并确保及时的数据处理。以下是创建和管理触发式任务、注意事项、限制以及手动执行的详细说明。

创建触发式任务

Snowflake 中的触发式任务是可以在其他任务完成后或基于特定事件设置执行的任务。

语法

要创建触发式任务，您需要定义任务的依赖项和它应执行的 SQL 命令。以下是一个示例：

CREATE TASK dependent_task
  AFTER parent_task
  WAREHOUSE = my_warehouse
  SCHEDULE = 'USING CRON 0 6 * * * UTC'
  COMMENT = 'Runs after parent_task completes'
AS
  CALL process_data_procedure();

组成部分

AFTER parent_task： 指定 dependent_task 应在 parent_task 完成后运行。
WAREHOUSE： 定义要使用的计算资源。
SCHEDULE： 设置执行计划。尽管已指定，但任务将在 parent_task 完成后执行。
COMMENT： 可选的任务描述。
AS： 指定要执行的 SQL 命令或过程。

触发式任务创建示例

假设您有一个从外部源摄取数据的任务，并且希望在数据摄取完成后由另一个任务处理这些数据。设置方法如下：

CREATE TASK ingest_data_task
  WAREHOUSE = data_warehouse
  SCHEDULE = 'USING CRON 0 1 * * * UTC'
  COMMENT = 'Ingests data from external source'
AS
  COPY INTO my_table
  FROM 's3://my-bucket/data/'
  FILE_FORMAT = (TYPE = 'CSV');

CREATE TASK process_data_task
  AFTER ingest_data_task
  WAREHOUSE = processing_warehouse
  COMMENT = 'Processes data after ingestion'
AS
  CALL process_data_procedure();

在此设置中：

process_data_task 将仅在 ingest_data_task 完成后运行。

触发式任务的注意事项

使用触发式任务时，请考虑以下方面：

任务依赖项

确保任务正确排序且依赖项准确定义。
注意任务完成的潜在延迟，这可能会影响依赖任务的执行。

错误处理

执行强大的错误处理和重试组件，以处理父任务中的故障，这可能会影响触发式任务的执行。
使用 Snowflake 的监控工具来跟踪任务的成功率和失败率。

资源管理

确保分配给任务的仓库适合工作负载。如果依赖任务需要大量资源，请规划足够的计算能力。
配置仓库的自动暂停和自动恢复，以有效管理成本。

计划冲突

要小心任务之间的计划冲突，尤其是在任务设置为在重叠时间运行的情况下。妥善管理计划，以避免资源争用。

依赖项和链接

涉及多个依赖任务的复杂工作流可能难以管理。请跟踪任务链接及其状态，以避免执行问题。

依赖管理复杂性

管理涉及多个任务的复杂依赖项可能会变得很麻烦。确保任务关系透明且易于管理，以避免问题。

手动执行任务

除了自动调度和触发外，您还可以手动执行 Snowflake 中的任务。这对于测试或临时执行任务很有用。

手动运行任务

要手动执行任务，请使用 SYSTEM$TASK_EXECUTE 函数。此函数允许您按需运行任务。

示例

在此示例中，my_task 将被手动执行，而无论其计划时间或依赖项如何。

通过 SQL 手动触发任务

对于依赖于其他任务的任务，您可以运行 SQL 命令直接模拟任务触发。这对于测试任务执行很有用。

CALL SYSTEM$TASK_EXECUTE('ingest_data_task');
CALL SYSTEM$TASK_EXECUTE('process_data_task');

手动执行注意事项

测试： 在将任务计划用于自动运行时，请使用手动执行来测试任务并验证其行为。
故障排除： 手动执行任务以排除故障或在常规计划之外执行临时数据处理。

为任务设置会话参数

Snowflake 中的会话参数用于配置任务运行会话的各种设置。这些参数会影响 SQL 命令的执行方式，包括查询性能和资源使用等方面的因素。设置会话参数对于优化任务执行并确保任务在期望的条件下运行至关重要。

会话参数会影响任务的执行环境。它们可用于自定义设置，例如：

查询超时： 设置查询在被终止之前可以运行多长时间。
资源限制： 定义资源使用限制，例如 CPU 或内存。
结果缓存： 控制是否缓存查询结果。

设置会话参数的语法

可以使用 ALTER SESSION 语句在任务定义中设置会话参数。以下是一个示例：

CREATE TASK my_task
  WAREHOUSE = my_warehouse
  SCHEDULE = 'USING CRON 0 6 * * * UTC'
  COMMENT = 'Task with session parameters'
AS
  ALTER SESSION SET STATEMENT_TIMEOUT_IN_SECONDS = 3600;
 
  -- Your SQL command or stored procedure
  CALL my_procedure();

在此示例中，会话参数 STATEMENT_TIMEOUT_IN_SECONDS 设置为 3600 秒（1 小时），确保任务内的 SQL 语句或过程的最长执行时间为 1 小时。

常用会话参数

STATEMENT_TIMEOUT_IN_SECONDS： 指定语句在被终止之前可以运行的最大时间。
QUERY_ACCELERATION_ENABLED： 控制是否为会话启用查询加速。
RESULT_CACHING： 确定是否缓存查询结果以提高性能。

示例：设置多个参数

CREATE TASK advanced_task
  WAREHOUSE = my_warehouse
  COMMENT = 'Task with multiple session parameters'
AS
  ALTER SESSION SET STATEMENT_TIMEOUT_IN_SECONDS = 1800;
  ALTER SESSION SET RESULT_CACHING = TRUE;
    INSERT INTO target_table
  SELECT * FROM source_table;

查看您帐户的任务历史记录

查看 Snowflake 中的任务历史记录有助于监控和故障排除任务，因为它提供了任务执行的详细日志，包括成功、失败和执行时间。

访问任务历史记录

Snowflake 提供 INFORMATION_SCHEMA.TASK_HISTORY 视图来访问有关任务的详细历史信息。

查看任务历史记录的示例查询

SELECT
  TASK_NAME,
  START_TIME,
  END_TIME,
  STATE,
  ERROR_MESSAGE
FROM
  INFORMATION_SCHEMA.TASK_HISTORY
WHERE
  START_TIME > CURRENT_DATE - INTERVAL '7 DAY'
ORDER BY
  START_TIME DESC;

在此查询中：

TASK_NAME 显示任务的名称。
START_TIME 和 END_TIME 提供任务的执行时间。
STATE 指示任务是成功、失败还是被取消。
ERROR_MESSAGE 显示任务失败时的任何错误消息。

过滤和排序任务历史记录

您可以根据不同标准过滤和排序任务历史记录，以查找特定的任务执行：

按任务名称： 查看特定任务的历史记录。

SELECT *
FROM INFORMATION_SCHEMA.TASK_HISTORY
WHERE TASK_NAME = 'my_task'
ORDER BY START_TIME DESC;

按执行状态： 只查看失败的任务。

SELECT *
FROM INFORMATION_SCHEMA.TASK_HISTORY
WHERE STATE = 'FAILED'
ORDER BY START_TIME DESC;

了解任务历史记录列

TASK_NAME： 任务的名称。
START_TIME： 任务开始的时间戳。
END_TIME： 任务完成的时间戳。
STATE： 任务的执行状态（SUCCEEDED、FAILED、CANCELLED）。
ERROR_MESSAGE： 执行期间遇到的任何错误的详细信息。

使用任务历史记录进行故障排除

要对任务进行故障排除，请关注：

错误消息： 查看错误消息以了解任务失败的原因。
执行时间： 检查任务是否花费的时间比预期长，并在必要时调整参数或优化查询。
状态更改： 查看任务状态的模式，以识别任务依赖项或调度中的问题。

任务成本

了解 Snowflake 中的任务成本对于有效管理您的数据处理预算至关重要。Snowflake 根据计算资源的使用时间收费，任务也不例外。

成本组成部分

计算积分： Snowflake 按计算积分收费。消耗的积分数量取决于虚拟仓库的大小及其使用时长。
仓库大小： 较大的仓库每小时消耗的积分更多。运行任务的仓库大小将直接影响成本。
任务执行时间： 运行时间长的任务会消耗更多积分。高效的 SQL 查询和优化的任务配置有助于最大程度地减少执行时间和成本。

监控任务成本

资源监视器： 设置资源监视器以跟踪积分使用情况并避免意外费用。当达到积分限制时，资源监视器可以发送警报或暂停仓库。

示例：创建资源监视器

CREATE RESOURCE MONITOR task_monitor
  WITH CREDIT_QUOTA = 200
  ALERT_THRESHOLD = 80
  NOTIFICATION_EMAIL = 'admin123@exmple.com';

查询成本数据： 使用 ACCOUNT_USAGE 视图来查看计算资源的成本和使用情况。

示例：查看计算积分使用情况

SELECT
  WAREHOUSE_NAME,
  SUM(CREDITS_USED) AS total_credits
FROM
  ACCOUNT_USAGE.WAREHOUSE_LOAD_HISTORY
WHERE
  START_TIME >= CURRENT_DATE - INTERVAL '1 MONTH'
GROUP BY
  WAREHOUSE_NAME;

用户管理的仓库让您可以控制用于任务的计算资源。您可以根据具体需求创建、配置和管理仓库。

创建仓库

CREATE WAREHOUSE my_warehouse
  WITH
  WAREHOUSE_SIZE = 'LARGE'
  AUTO_SUSPEND = 300
  AUTO_RESUME = TRUE;

在此示例中

WAREHOUSE_SIZE 指定仓库的大小。
AUTO_SUSPEND 设置仓库不活动时自动暂停的时间（以秒为单位）。
AUTO_RESUME 允许在需要时自动恢复仓库。

扩展仓库

您可以根据工作负载向上或向下扩展仓库。

示例：向上扩展

ALTER WAREHOUSE my_warehouse
  SET WAREHOUSE_SIZE = 'X-LARGE';

示例：横向扩展（多集群）

ALTER WAREHOUSE my_warehouse
  SET MIN_CLUSTER_COUNT = 1
  SET MAX_CLUSTER_COUNT = 5;

管理成本

自动暂停和自动恢复： 配置这些功能以最大程度地减少成本，确保仓库仅在需要时运行。
监控使用情况： 定期审查仓库性能，并调整大小或配置以平衡成本和性能。

无服务器计算模型

Snowflake 中的无服务器计算模型消除了用户直接管理计算资源的需求。Snowflake 会自动处理扩展和资源分配，从而简化管理并可能降低成本。

无服务器模型的特点

自动扩展： Snowflake 根据工作负载需求自动扩展计算资源，无需用户干预。
按需付费： 您根据实际计算使用量付费，这对于可变或不可预测的工作负载可能更具成本效益。
无基础设施管理： 您无需担心配置、扩展或管理计算集群。

用例

临时查询： 适用于运行临时查询或一次性分析，因为这些场景的计算需求不可预测。
开发和测试： 适用于工作负载不一致的开发和测试环境。

转向无服务器

如果您想利用 Snowflake 的无服务器模型，请确保：

工作负载特性： 您的工作负载非常适合无服务器环境。具有高度可变或不可预测资源需求的任务是理想的选择。
成本管理： 监控使用情况和成本，以确保无服务器模型与您特定用例的用户管理仓库相比具有成本效益。

Snowflake 中的安全和访问控制

在 Snowflake 中创建和管理任务时，安全和访问控制对于确保任务由具有适当权限的授权用户设计和执行至关重要。Snowflake 使用基于角色的访问控制模型来管理这些权限。

创建任务的访问控制权限

要创建和管理 Snowflake 中的任务，您需要对对象和角色具有特定权限。以下是所需权限的摘要：

Object	权限	注意事项
仓库	USAGE	角色必须对任务将使用的仓库具有 USAGE 权限。这允许任务访问计算资源以进行执行。
模式	USAGE	角色必须对任务所在的模式具有 USAGE 权限。这使得角色能够与模式内的对象进行交互。
数据库	USAGE	角色必须对模式所在的数据库具有 USAGE 权限。这允许角色访问数据库对象和模式。
任务	CREATE TASK	角色必须具有 CREATE TASK 权限才能在模式中定义新任务。此权限对于创建任务至关重要。
任务	MONITOR TASK	要监控任务的状态和历史记录，角色必须具有 MONITOR TASK 权限。这允许角色查看任务执行详细信息和日志。
角色	MANAGE GRANTS	角色必须具有 MANAGE GRANTS 权限才能授予或撤销其他角色所需的权限，包括与任务相关的权限。

权限分配示例

将权限分配给角色

-- Grant USAGE on a warehouse to a role
GRANT USAGE ON WAREHOUSE my_warehouse TO ROLE my_role;

-- Grant USAGE on a schema to a role
GRANT USAGE ON SCHEMA my_schema TO ROLE my_role;

-- Grant USAGE on a database to a role
GRANT USAGE ON DATABASE my_database TO ROLE my_role;

-- Grant CREATE TASK privilege on a schema to a role
GRANT CREATE TASK ON SCHEMA my_schema TO ROLE my_role;

-- Grant MONITOR TASK privilege on a schema to a role
GRANT MONITOR TASK ON SCHEMA my_schema TO ROLE my_role;

管理任务安全

角色层次结构

授予角色： 确保角色具有适当的层次结构，并授予了创建和管理任务所需的必要权限。
角色分配： 根据用户对创建、监控或管理任务的需求，将角色分配给用户。

最小权限原则

最小权限原则： 只授予任务所需的权限。避免授予不适合角色职责的过量权限。

审计和监控

任务历史记录： 定期查看任务历史记录和日志，以确保任务按预期执行并监控任何未经授权的活动。

查看任务历史记录的示例查询

SELECT
  TASK_NAME,
  START_TIME,
  END_TIME,
  STATE,
  ERROR_MESSAGE
FROM
  INFORMATION_SCHEMA.TASK_HISTORY
WHERE
  START_TIME > CURRENT_DATE - INTERVAL '7 DAY'
ORDER BY
  START_TIME DESC;

访问控制审查： 定期审查角色分配和权限，以确保它们符合当前的安全策略和操作需求。

在 Snowflake 中运行任务所需的权限

在 Snowflake 中创建任务后，任务所有者和执行任务的角色必须拥有特定权限才能确保任务正确运行。以下是所需权限的摘要：

Object	权限	注意事项
任务	OPERATE TASK	角色必须具有 OPERATE TASK 权限才能启动、停止或暂停任务。这允许控制任务执行。
仓库	USAGE	角色必须对任务使用的仓库具有 USAGE 权限。这是任务访问计算资源的必要条件。
模式	USAGE	角色必须对包含任务的模式具有 USAGE 权限。这允许与模式中的对象进行交互。
数据库	USAGE	角色必须对模式所在的数据库具有 USAGE 权限。这确保了对数据库对象和模式的访问。
表/视图	SELECT/INSERT/UPDATE/DELETE	根据任务操作，角色必须对涉及的表或视图具有适当的权限（例如，SELECT 用于查询，INSERT 用于添加数据）。

运行任务的权限分配示例

将权限分配给角色

-- Grant OPERATE TASK privilege on a task to a role
GRANT OPERATE TASK ON TASK my_task TO ROLE my_role;

-- Grant USAGE on a warehouse to a role
GRANT USAGE ON WAREHOUSE my_warehouse TO ROLE my_role;

-- Grant USAGE on a schema to a role
GRANT USAGE ON SCHEMA my_schema TO ROLE my_role;

-- Grant USAGE on a database to a role
GRANT USAGE ON DATABASE my_database TO ROLE my_role;

-- Grant necessary table/view privileges to a role
GRANT SELECT, INSERT ON TABLE my_table TO ROLE my_role;

附加考虑事项

任务执行和调度
- 计划管理： 如果任务旨在自动运行，请确保其正确调度。验证调度设置是否正确，并与预期的执行时间一致。
错误处理和监控
- 错误处理： 在任务中实现错误处理以管理异常和故障。定期审查任务日志和错误消息以及时解决问题。

查看任务执行状态的示例查询

SELECT
  TASK_NAME,
  STATE,
  LAST_SUCCESSFUL_RUN,
  LAST_FAILED_RUN,
  ERROR_MESSAGE
FROM
  INFORMATION_SCHEMA.TASK_HISTORY
WHERE
  TASK_NAME = 'my_task'
ORDER BY
  LAST_SUCCESSFUL_RUN DESC;

角色管理

角色分配： 确保根据用户运行或管理任务的需求，为其分配适当的角色。使用 Snowflake 的基于角色的访问控制来有效授予和管理这些权限。

最小权限原则

仅授予必要的权限： 遵循最小权限原则，仅授予运行任务所需的必要权限。避免提供过多的权限。

管理 Snowflake 中的任务权限和角色

在 Snowflake 中使用任务时，有效管理权限和角色对于维护安全和操作效率至关重要。以下是有关查看任务历史记录、创建自定义角色来管理任务以及处理系统服务任务执行的详细指南。

查看任务历史记录

要监控任务的执行和性能，您可以查询 Snowflake 的 INFORMATION_SCHEMA.TASK_HISTORY 视图。此视图提供有关任务执行的详细信息，包括成功、失败和执行时间。

查看任务历史记录的示例查询

SELECT
  TASK_NAME,
  START_TIME,
  END_TIME,
  STATE,
  ERROR_MESSAGE
FROM
  INFORMATION_SCHEMA.TASK_HISTORY
WHERE
  START_TIME >= CURRENT_DATE - INTERVAL '7 DAY'
ORDER BY
  START_TIME DESC;

列

TASK_NAME： 任务的名称。
START_TIME： 任务开始的时间戳。
END_TIME： 任务完成的时间戳。
STATE： 任务的执行状态（例如，SUCCEEDED、FAILED）。
ERROR_MESSAGE： 任务失败时的任何错误消息。

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

创建可以创建任务的角色

要创建可以创建任务的角色，您需要授予在要创建任务的模式上 CREATE TASK 权限。

示例：创建自定义角色并分配权限

-- Create a custom role
CREATE ROLE task_creator_role;

-- Grant CREATE TASK privilege on a schema to the custom role
GRANT CREATE TASK ON SCHEMA my_schema TO ROLE task_creator_role;

-- Grant USAGE on the database and schema
GRANT USAGE ON DATABASE my_database TO ROLE task_creator_role;
GRANT USAGE ON SCHEMA my_schema TO ROLE task_creator_role;

-- Grant USAGE on the warehouse used by the task
GRANT USAGE ON WAREHOUSE my_warehouse TO ROLE task_creator_role;

创建可以管理任务的角色

要管理任务，包括启动、停止或监控任务，请授予 OPERATE TASK 和 MONITOR TASK 权限。

示例：创建用于任务管理的自定义角色

-- Create a custom role
CREATE ROLE task_admin_role;

-- Grant OPERATE TASK privilege on tasks in the schema
GRANT OPERATE TASK ON SCHEMA my_schema TO ROLE task_admin_role;

-- Grant MONITOR TASK privilege on tasks in the schema
GRANT MONITOR TASK ON SCHEMA my_schema TO ROLE task_admin_role;

-- Grant USAGE on the database and schema
GRANT USAGE ON DATABASE my_database TO ROLE task_admin_role;
GRANT USAGE ON SCHEMA my_schema TO ROLE task_admin_role;

-- Grant USAGE on the warehouse used by the task
GRANT USAGE ON WAREHOUSE my_warehouse TO ROLE task_admin_role;

删除任务所有者角色

如果您需要删除拥有任务的角色，请确保在删除角色之前，该角色未分配给任何活动任务或用户。在执行此操作之前，将任何必需的权限重新分配给其他角色。

示例：删除角色

-- Drop the role
DROP ROLE task_creator_role;

确保您已将任何必需的权限或任务重新分配给其他角色，然后再删除该角色。

系统服务任务执行

Snowflake 中的系统服务任务由 Snowflake 内部管理，不直接由用户控制。这些任务包括维护任务、优化和系统管理操作。

监控系统服务任务

虽然您无法直接管理系统服务任务，但可以监控它们对您环境的影响：

性能影响： 关注性能指标和系统运行状况，以了解系统服务任务可能如何影响您的工作负载。

监控仓库性能的示例查询

SELECT
  WAREHOUSE_NAME,
  AVG(CREDITS_USED) AS avg_credits
FROM
  ACCOUNT_USAGE.WAREHOUSE_LOAD_HISTORY
WHERE
  START_TIME >= CURRENT_DATE - INTERVAL '7 DAY'
GROUP BY
  WAREHOUSE_NAME;

资源使用情况： 定期查看资源使用情况，以确保系统服务任务不会导致意外的性能问题。

与系统服务任务交互

计划维护： Snowflake 会自动安排维护任务和升级。用户会提前收到有关可能影响其环境的任何重大更改的通知。
支持请求： 如果您遇到与系统服务任务相关的问题，请联系 Snowflake 支持寻求帮助。

下一主题Snowflake 任务 DDL

Python

Java

.Net Framework

AI, ML and Data Science

Cloud Technology

B.Tech and MCA

Web Technology

PHP

Software Testing

Technical Interview

Java Interview

Python

Web Interview

Database Interview

B.Tech / MCA

Important Interview

Software Testing Interview

Company Interviews

Online Compilers

Multiple Choice Questions

Snowflake 教程

Snowflake 任务

引言

什么是 Snowflake 任务？

为什么要使用 Snowflake 任务？

Snowflake 任务如何工作

任务创建工作流

任务需求

创建任务

配置任务调度器

设置任务依赖项

管理任务执行

监控和故障排除任务

文档记录和审查

触发式任务

创建触发式任务

触发式任务的注意事项

手动执行任务

为任务设置会话参数

设置会话参数的语法

常用会话参数

查看您帐户的任务历史记录

过滤和排序任务历史记录

了解任务历史记录列

使用任务历史记录进行故障排除

任务成本

成本组成部分

监控任务成本

无服务器计算模型

Snowflake 中的安全和访问控制

创建任务的访问控制权限

权限分配示例

管理任务安全

在 Snowflake 中运行任务所需的权限

附加考虑事项

管理 Snowflake 中的任务权限和角色

查看任务历史记录

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

创建可以管理任务的角色

删除任务所有者角色

系统服务任务执行

与系统服务任务交互

相关帖子

Snowflake 工作管理

Snowflake 流

Snowflake 列式数据库设计，面向实时分析

Snowflake 安全性和合规性

Snowflake 元数据管理中心

Snowflake 数据管道和编排

Snowflake 基于 SQL 的分析

使用 Snowflake 构建可扩展的数据解决方案

Snowflake 中的未来功能

Snowflake 安全数据共享

订阅 Tpoint Tech

联系信息

关注我们

教程

面试题

在线编译器