Snowflake 交互式表和交互式仓库¶

创建交互式表¶

表创建遵循标准 CTAS (CREATE TABLE AS SELECT) 语法，并附加了 INTERACTIVE 关键字来定义表类型。

CREATE INTERACTIVE TABLE 命令还需要 CLUSTER BY 子句。在 CLUSTER BY 子句中指定一列或多列，以匹配对时间要求最高的查询中的 WHERE 子句。您在 CLUSTER BY 子句中指定的列可以显著影响对交互式表的查询性能。因此，请谨慎选择群集列。有关选择最佳群集列的更多信息，请参阅 群集密钥和聚类表。

使用以下命令创建一个交互式表，其中包含与标准表相同的列和数据。CLUSTER BY 子句引用源表中名为 id 的列。

CREATE INTERACTIVE TABLE
  IF NOT EXISTS orders
  CLUSTER BY (id)
AS
  SELECT * FROM demoSource;

TARGET_LAG = '<num> { seconds | minutes | hours | days }'

CREATE INTERACTIVE TABLE my_dynamic_interactive_table
  CLUSTER BY (c1, c2)
  TARGET_LAG = '20 minutes'
  WAREHOUSE = s_maintenance_wh
  INITIALIZATION_WAREHOUSE = xl_initial_wh
AS SELECT c1, SUM(c2) FROM my_source_table GROUP BY c1;

ALTER INTERACTIVE TABLE ``my_dynamic_interactive_table`` REFRESH.

创建交互式仓库¶

创建交互式表后，要实现最佳查询性能，需要使用交互式仓库。在 CREATE WAREHOUSE 或 CREATE OR REPLACE WAREHOUSE 命令中指定关键字 INTERACTIVE。

（可选）您可以指定 TABLES 子句，其中包含以逗号分隔的交互式表名称列表。使用该子句会立即将这些交互式表与交互式仓库关联起来。

以下命令创建了一个与名为 orders 的交互式表关联的交互式仓库。在这种情况下，您可以立即运行 USE WAREHOUSE 命令，并开始对交互式表运行查询：

CREATE OR REPLACE INTERACTIVE WAREHOUSE interactive_demo
  TABLES (orders)
  WAREHOUSE_SIZE = 'XSMALL';

以下命令创建了一个没有关联交互式表的交互式仓库。在这种情况下，您可以在之后运行 ALTER WAREHOUSE 命令，将交互式表与交互式仓库相关联：

CREATE OR REPLACE INTERACTIVE WAREHOUSE interactive_demo
  WAREHOUSE_SIZE = 'XSMALL';

创建交互式仓库后，它将保持暂停状态，直到您将其恢复。您可以为交互式仓库配置自动暂停和自动恢复。交互式仓库的最短自动暂停间隔为 24 小时（86400 秒）。恢复和暂停交互式仓库 是 Web 令牌 ()、 令牌或 编程访问令牌 。有关详细信息，请参阅 恢复和暂停交互式仓库。

交互式仓库的查询最佳实践¶

交互式仓库针对具有 选择性工作负载 的查询进行了优化。这意味着与其他查询类型相比，具有良好选择性的查询在性能方面有更多的改进。

SELECT col1, col4, AVG(col_x)
  FROM my_table
  GROUP BY col1, col4;

SELECT * FROM my_table;

SELECT col1, col2
  FROM my_table
  WHERE
    col_x IN (1,4,7,8)
    AND event_time >=
      DATEADD(hour, -1, CURRENT_TIMESTAMP());

SELECT col1, col2
  FROM my_table
  WHERE
    event_time >=
      DATEADD(day, -365, CURRENT_TIMESTAMP());

大型联接（如联接两个事实表）等其他复杂操作，或计算密集型表达式（如正则表达式）可能会因计算资源使用量增加而导致并发性降低。有关针对这些情况进行优化的信息，请参阅 选择交互式仓库的大小。

交互式表的数据布局最佳实践¶

交互式表遵循标准 Snowflake 性能最佳实践。特别是，交互式表受益于 聚类良好的表，该表根据您要筛选的相同列进行排序。例如，如果您的查询经常筛选 TIMESTAMP 列（如 sale_date），则可以在创建交互式表时使用该列作为群集密钥。例如，您可以按如下方式创建交互式表：

CREATE INTERACTIVE TABLE product_sales (<column definitions>) CLUSTER BY (sale_date);

这样，筛选 sale_date 的 SELECT 查询可以快速跳过所有不相关的数据并返回结果。例如，以下查询通过测试 sale_date 列对日期范围进行筛选：

SELECT ... WHERE sale_date > '2025-10-24' AND ...

有关选择最佳群集密钥的更多详细信息，请参阅 群集密钥和聚类表。

选择交互式仓库的大小¶

完成所有查询和布局优化后，请考虑 扩展仓库 以满足需求。交互式仓库的大小范围从 XSMALL 到 3XLARGE，以及 多集群仓库。

建议您首先根据交互式表中 工作数据集 的大致大小来调整仓库大小。工作数据集是指经常查询的数据部分。例如，如果您的查询通常只查询过去七天的销售数据，则工作集是交互式表中与这七天相对应的部分。

这是因为交互式仓库使用 本地存储缓存。虽然整个数据集（表）的数据始终可访问，但访问非缓存数据确实会在首次读取时产生更高的读取延迟。

选择适合工作负载需求的仓库大小。试验特定的数据和工作负载，以确定交互式仓库的最佳大小。

我们建议根据有效数据集的大小，从以下仓库规格开始配置。（受不同云平台及区域的硬件差异影响，以下内容仅供参考）

将交互式表添加到交互式仓库¶

要获得交互式表的最佳查询性能，应使用交互式仓库。

在使用交互式仓库查询交互式表之前，必须执行一次操作，将该交互式表添加到交互式仓库。否则，在交互式仓库中查询该表时，会出现 object not found 错误。如果您没有在 CREATE INTERACTIVE WAREHOUSE 命令中使用 TABLES 子句指定与交互式仓库关联的交互式表，则稍后可以使用 ALTER WAREHOUSE 命令进行指定。

以下命令将 orders 表与 interactive_demo 仓库相关联。您可以使用 ADD TABLES 子句指定多个表名，并用逗号分隔。

ALTER WAREHOUSE interactive_demo ADD TABLES (orders);

如果交互式表已与交互式仓库关联，则该命令会成功，但不起作用。您可以将一个交互式表与多个交互式仓库相关联。

此操作将启动缓存预热过程。缓存预热时间基于数据大小和仓库大小。XS 仓库预热时间约为 300-350MB/秒。表越大，缓存预热时间越长。仓库越大，预热速度越快。

预热过程不会阻止仓库接受新查询。预热的优先级是：1.用户发出的查询 2.通过自动刷新或其他数据引入方式新添加的微分区 3.任何现有数据

由于缓存预热取决于您的查询，监控缓存是否已预热的最佳方式是查看 Snowsight 查询配置文件 中的远程读取百分比。有关以编程方式访问查询运算符统计信息的信息，请参阅 GET_QUERY_OPERATOR_STATS。在理想的执行场景中，低延迟查询的远程读取百分比应为 0%。

从交互式仓库中移除交互式表¶

您可以通过运行带 DROP TABLES 子句的 ALTER WAREHOUSE 命令，从交互式仓库中分离一个或多个交互式表。

ALTER WAREHOUSE interactive_demo DROP TABLES (orders, customers);

使用搜索优化进行点查找¶

当您对交互式表执行点查找查询时，建议添加 搜索优化。点查找是对单列进行筛选以检索一行或多行数据的查询。WHERE some_id = some_UUID 是一个很好的例子。

交互式物化视图的最佳实践¶

使用交互式表创建物化视图时，请遵循以下准则：

• 交互式物化视图的工作方式与常规物化视图类似。它必须基于交互式表。

• 交互式物化视图及其所基于的源交互式表必须添加到同一个交互式仓库中。否则，在交互式仓库中查询该物化视图时，会出现 object not found 错误。

• 无论是交互式视图还是标准视图，物化视图中都不支持联接。构建查询以从单个基表中汇总或筛选。

• 不能将交互式表或交互式物化视图用作 动态表 的数据源。

• 在考虑交互式物化视图的候选项时，请选择经常运行且计算成本高昂的聚合查询

恢复和暂停交互式仓库¶

以下命令可恢复交互式仓库。您必须在创建仓库后执行此操作，因为该仓库是在暂停状态下创建的：

ALTER WAREHOUSE interactive_demo RESUME;

如果您手动暂停了仓库，您还可以执行此操作，以通过该仓库开始运行查询。

恢复后，在预热缓存期间，查询速度会很慢。可能需要几分钟到一个小时左右，具体取决于该表中的数据量。

以下命令可暂停交互式仓库：

ALTER WAREHOUSE interactive_demo SUSPEND;

CREATE INTERACTIVE WAREHOUSE interactive_demo
  WAREHOUSE_SIZE = 'XSMALL'
  AUTO_SUSPEND = 86400
  AUTO_RESUME = TRUE;

ALTER WAREHOUSE interactive_demo SET
  AUTO_SUSPEND = 86400
  AUTO_RESUME = TRUE;

基于任务的多集群大小调整¶

您可以通过计划任务调整 MIN_CLUSTER_COUNT 参数。

-- 1) Task to scale OUT during business hours
CREATE OR REPLACE TASK mcw_scale_out_morning
  WAREHOUSE = my_wh          -- the warehouse that *executes the task*
  SCHEDULE = 'USING CRON 0 8 * * * UTC'   -- 08:00 UTC daily
AS
  ALTER WAREHOUSE my_wh      -- the warehouse you want to change (can be same or different)
    SET
      MIN_CLUSTER_COUNT = 10;  -- optional: ECONOMY or STANDARD

-- 2) Task to scale IN after hours
CREATE OR REPLACE TASK mcw_scale_in_evening
  WAREHOUSE = my_wh
  SCHEDULE = 'USING CRON 0 20 * * * UTC'  -- 20:00 UTC daily
AS
  ALTER WAREHOUSE my_wh
    SET
      MIN_CLUSTER_COUNT = 2;

建议使用自动扩展策略设置 MAX_CLUSTER_COUNT 来调整工作负载的峰值并发性。

删除交互式仓库¶

您可以运行 DROP WAREHOUSE 命令来完全移除交互式仓库。删除交互式仓库会移除该仓库与任何交互式表之间的关联。但是，您仍然可以使用其他交互式仓库来查询这些相同的交互式表。

查询交互式表¶

在查询会话中，确保当前会话的仓库是交互式仓库：

USE WAREHOUSE interactive_demo;

此后，您可以正常查询交互式表。

基准测试最佳实践¶

在测试环境中评估交互式表的性能时，请遵循以下最佳实践，以避免出现不一致或误导性的结果：

• 关闭查询结果缓存，使多次基准测试运行之间的基准测试结果保持一致。您可以通过设置 USE_CACHED_RESULT 会话参数，在账户、用户和会话级别关闭查询结果缓存。这样一来，查询仅使用来自交互式仓库的表数据缓存。如果您在生产环境中打开结果缓存，您可以获得与基准测试相当或更好的性能。

• 由于交互式仓库需要一些时间来预热表数据缓存，因此在创建或恢复交互式仓库后，请等待一段时间，然后再测试查询性能。这模拟了仓库长时间保持活动状态的典型生产配置。Snowflake 对缓存预热过程进行了优化。因此，让 Snowflake 完成此过程比通过运行示例查询自行预热缓存更高效。

• 在将交互式表的性能与标准 Snowflake 表进行比较时，不要在标准表和交互式表之间交错查询。应先在标准表上运行完整的基准测试，然后在交互式表上运行相同的测试。

• 在与其他数据库系统进行比较基准测试时，请确保交互式表中的群集列与查询中的 WHERE 子句谓词匹配。有关选择最佳群集列的更多信息，请参阅 群集密钥和聚类表。尤其要注意，请勿对具有高基数（例如唯一 IDs 或时间戳）的列进行聚类。

• 如果查询简短且简单，则可以将交互式仓库的 MAX_CONCURRENCY_LEVEL 参数设置为更高值，从而实现更高的并发性。

交互式仓库的限制¶

• Snowflake 交互式仓库针对短期运行的查询进行了优化。SELECT 命令的查询超时值默认为五秒。五秒钟后，查询将被取消。您可以降低查询超时值，但不能提高该值。这样做是为了防止长时间运行的查询导致交互式仓库资源不足，并降低低延迟查询的性能。某些类型的命令不受五秒超时间隔的限制，例如 SHOW 和 INSERT OVERWRITE。

• 如果查询持续超时，则表明该查询可能不适用于交互式仓库。通常，应用一些性能调优技术有助于减少查询延迟。有关更多详细信息，请参阅 交互式表性能注意事项。

• 交互式仓库支持自动暂停和自动恢复，最短自动暂停间隔为 24 小时（86400 秒）。当您恢复交互式仓库时，由于数据缓存需要再次预热，因此预计会出现显着的查询延迟。有关更多信息，请参阅 恢复和暂停交互式仓库。

• 您无法从交互式仓库查询标准 Snowflake 表。要在同一会话中查询标准表和交互式表，请运行 USE WAREHOUSE，切换到相应仓库类型。

• 您最多可以向交互式仓库添加 10 个交互式表。这是为了防止系统过载而采取的临时限制。此限制将来会增加。如果您需要添加 10 个以上的交互式表，请联系 Snowflake 支持部门。

• 在交互式仓库中，您不能运行 CALL 命令 来调用存储过程。

• 您不能使用 ->> 管道运算符。此运算符在后台使用存储过程。

交互式表的限制¶

• 交互式表不支持以下功能：

  • 数据操作语言 (DML) 命令，例如 UPDATE 和 DELETE。推荐的工作流程是使用自动刷新交互式表（即通过 TARGET_LAG 设置）并将 DML 应用于源表。自动刷新机制比对交互式表使用 DML 更高效且更具成本效益。您可以执行的唯一 DML 是 INSERT OVERWRITE。

  • 故障安全。此数据恢复机制不适用于交互式表。但是，您仍然可以将 Time Travel 与交互式表结合使用。

  • 行时间戳。您不能在交互式表上启用行时间戳。这是一个临时限制。

  • 查询见解。目前，在交互式表上执行的查询不会收集这些数据，也无法使用这些数据，以帮助减少查询执行延迟。

• 您不能执行以下操作：

  • 使用交互式表作为标准（非交互式）物化视图的源。要在交互式表上创建物化视图，请使用 INTERACTIVE 关键字。请参阅 对交互式表的物化视图支持。

  • 修改交互式表的属性，方法是使用 ALTER TABLE 子句，例如 ADD COLUMN 或 REMOVE COLUMN。您 可以 执行的 ALTER TABLE 操作包括：

    • 重命名表。

    • 修改列以设置或取消设置注释。

    • 设置或取消设置列的掩码策略。

    • 为表添加或取消设置 掩码策略、联接策略、聚合策略 或 行访问策略。

    • 为表添加 存储生命周期策略，或从表中删除存储生命周期策略。

  • 将 流 与交互式表结合使用。

  • 创建以交互式表为基表的 动态表。

  • 在对交互式表进行查询时，请使用 RESAMPLE 子句。

  • 使用 CREATE INTERACTIVE TABLE 或 ALTER TABLE 设置 Time Travel 保留期。交互式表会继承父架构、数据库或账户中的值 DATA_RETENTION_TIME_IN_DAYS。