Snowflake Data Clean Room:提供商 API 参考指南

概述

本参考指南列出了 Clean Rooms API 中的存储过程,允许提供商创建、配置和共享 Clean Room。

过程存在于以下架构中:

  • samooha_by_snowflake_local_db.provider – 特定于提供商的过程。这些过程只能在当前账户创建的 Clean Room 上调用。

  • samooha_by_snowflake_local_db.consumer – 特定于使用者的过程。这些过程只能在当前账户受邀作为使用者的 Clean Room 上调用。

  • samooha_by_snowflake_local_db.library – Clean Room 创建者(提供商)或 Clean Room 协作者(使用者)调用的一般过程。

支持 Snowflake 过程的任何命令行环境都可以访问这些过程,包括笔记本、工作簿和 CLI

要求

API 需要 samooha_app_role 角色和 app_wh 仓库。在使用本文所述的任何过程之前,请执行以下命令:

USE ROLE samooha_app_role;
USE WAREHOUSE app_wh;
Copy

如果您没有 SAMOOHA_APP_ROLE 角色,请联系账户管理员。

创建、配置和删除 Clean Room

provider.view_cleanrooms

描述: 列出此提供商账户创建的所有现有 Clean Room。

实参:

返回: (表) 此提供商账户创建的 Clean Room 列表。Clean Room 无需与使用者共享、由使用者安装或使用。已删除的 Clean Room 将从数据库中清除,并且不显示在此列表中。

示例:

call samooha_by_snowflake_local_db.provider.view_cleanrooms();
Copy

provider.describe_cleanroom

描述: 获取有关 Clean Room 的信息摘要,如模板、联接策略、列策略和使用者。

实参:

  • cleanroom_name(字符串) – 要获取信息的 Clean Room 的名称。

返回: (字符串) Clean Room 元数据摘要。

示例:

call samooha_by_snowflake_local_db.provider.describe_cleanroom($cleanroom_name);
Copy

provider.cleanroom_init

描述: 在账户中创建指定名称的 Clean Room。此过程可能需要一分钟或更长时间才能运行。在您调用 create_or_update_cleanroom_listing 后,Clean Room 才会在 Web 应用程序中或对协作者可见。

实参:

  • cleanroom_name(字符串) – Clean Room 名称,最多 80 个字符。名称包括 [A‑Z,a‑z,0‑9, ,_]。

  • distribution(字符串,可选) – 以下值之一:

    • INTERNAL(默认)– Clean Room 仅对同一组织内的用户可见,并且在 更改默认版本 之前不会触发安全扫描。

    • EXTERNAL – Clean Room 已做好生产准备,可以在组织外共享。Clean Room 在 更改默认版本 前触发安全扫描。如果要在创建 Clean Room 后更改分发,请调用 alter package,如下所示:

      alter application package samooha_cleanroom_<CLEANROOM_ID> SET DISTRIBUTION = EXTERNAL;
      
      Copy

返回: (字符串) 成功或失败消息。

示例:

-- Create an internal clean room
call samooha_by_snowflake_local_db.provider.cleanroom_init($cleanroom_name, 'INTERNAL');
Copy

provider.set_default_release_directive

描述: 指定协作者在 Web 应用程序中启动新的浏览器会话或从 API 访问 Clean Room 时加载的 Clean Room 的版本和补丁。必须在与使用者共享 Clean Room 之前调用。

无论何时上传或更改 Python 代码,Clean Room 应用程序都会创建一个新版本的 Clean Room。如果您希望为用户提供最新版本的服务,请使用新的版本号调用此过程。要查看可用版本并了解当前默认版本,请运行:

show versions in application package samooha_cleanroom_<CLEANROOM_ID>;
Copy

创建的所有 Clean Room 都有以下版本号和补丁号:

  • 版本:V1_0

  • 补丁:0

备注

如果 Clean Room 分布设置为 EXTERNAL,则只有在 Clean Room 安全扫描进入 APPROVED 状态后,才能调用此过程。要查看安全状态,请调用 view_cleanrooom_scan_status

实参:

  • cleanroom_name(字符串) – Clean Room 名称。

  • version(字符串) – 版本。必须始终为“V1_0”。

  • patch(字符串) – 使用者加载的补丁号。补丁号从 0 开始,每当有新的 Clean Room 版本可用时,都应该递增。您可以看到如上所述的可用版本。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.set_default_release_directive($cleanroom_name, 'V1_0', '0');
Copy

provider.drop_cleanroom

描述: 删除 Clean Room。安装了 Clean Room 的协作者将无法再访问或使用。下次刷新浏览器时,Clean Room 将不再显示在 Web 应用程序中。

实参:

  • cleanroom_name(字符串) – 要删除的 Clean Room 的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.drop_cleanroom($cleanroom_name);
Copy

provider.enable_consumer_run_analysis

描述: 让使用者能够在 Clean Room 运行分析。此功能默认在所有新的 Clean Room 中启用,因此,仅当您明确禁用了 Clean Room 的使用者运行分析时,才需要运行此过程。

重要

使用者安装 Clean Room 之前必须调用此过程。如果在安装 Clean Room 后更改了此功能,则必须重新安装 Clean Room 以反映新的配置。

实参:

  • cleanroom_name(字符串) – 允许使用者运行分析的 Clean Room 的名称。

  • consumer_accounts(字符串数组) – 要为之启用此功能的所有使用者的账户定位器。NOTE: 这些使用者必须已经添加到 Clean Room。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.enable_consumer_run_analysis($cleanroom_name, ['<CONSUMER_ACCOUNT_LOCATOR_1>']); 
Copy

provider.disable_consumer_run_analysis

描述: 防止指定使用者在指定 Clean Room 运行分析。默认情况下,允许所有使用者在 Clean Room 内运行分析。

重要

使用者安装 Clean Room 之前必须调用此过程。如果用户在安装 Clean Room 后更改了此配置,则需要重新安装 Clean Room 以反映新的配置。

实参:

  • cleanroom_name(字符串) – 正在禁用使用者运行分析的 Clean Room。

  • consumer_accounts(字符串数组) – 无法在此 Clean Room 中运行分析的使用者的账户定位器。NOTE: 这些使用者必须已经添加到 Clean Room。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.disable_consumer_run_analysis($cleanroom_name, ['<CONSUMER_ACCOUNT_LOCATOR_1>']); 
Copy

library.is_consumer_run_enabled

描述: 检查此 Clean Room 是否允许使用者运行分析。

实参:

  • cleanroom_name(字符串) – 要检查的 Clean Room 的名称。

返回: (字符串) 此 Clean Room 是否允许使用者运行分析。

示例:

call samooha_by_snowflake_local_db.library.is_consumer_run_enabled($cleanroom_name)
Copy

provider.create_or_update_cleanroom_listing

描述: 发布新 Clean Room 或更新现有 Clean Room。每当对 Clean Room 进行更改时,您都应该调用此方法,以确保将更改传播给使用者。

首次发布 Clean Room 时,可能需要一段时间才能在 Web 应用程序中看到 Clean Room(最多 15 分钟)。

如果您之后不调用此方法而对 Clean Room 进行更新,则不能保证这些更改会传播给使用者。

备注

在调用此过程之前,必须至少设置一次发布指令。 有关更多信息,请参阅 provider.set_default_release_directive

实参:

  • cleanroom_name(字符串) – 要发布或更新的 Clean Room 的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.create_or_update_cleanroom_listing($cleanroom_name);
Copy

provider.add_ui_form_customizations

描述: 定义在 Web 应用程序中访问时 Clean Room 中模板的 UI。当允许使用者选择模板参数(如表或列)时,这很有用。至少,您必须在 template_information 实参中指定 display_namedescriptionmethodology` 的值。

实参:

  • cleanroom_name(字符串):包含此模板的 Clean Room 的名称。提交的表单仅适用于指定 Clean Room 中的指定模板。

  • template_name(字符串):该 UI 适用的模板的名称。这不是使用 template_information.display_name 字段指定的用户可见的标题。

  • template_information(字典):UI 中向用户显示的信息。包含以下字段:

    • display_name必填):显示 Web 应用程序中模板的名称。

    • description必填):模板的描述。

    • methodology必填):说明使用者应如何使用表单执行分析。

    • warehouse_hints (对象):建议使用哪种类型的仓库来运行分析。这是一个具有以下字段的对象:

      • warehouse_size:请参阅 CREATE WAREHOUSE 中的 warehouse_size,了解有效值。

      • snowpark_optimized (布尔):是否使用 Snowpark 优化的仓库 来处理查询。对于大多数机器学习用例,Snowflake 建议 TRUE。

    • render_table_dropdowns (对象):是否显示默认下拉列表,让用户选择在查询中使用哪个提供商和/或使用者表。这是一个具有以下字段的对象:

      • render_consumer_table_dropdown (布尔,默认 = TRUE) 如果为 TRUE,则显示默认使用者表选择器。如果为 FALSE,则隐藏使用者表选择器。模板可以使用 my_table 模板变量以列表形式访问所选值。

      • render_provider_table_dropdown(布尔,默认 = TRUE) 如果为 TRUE,则显示默认提供商表选择器。如果为 FALSE,则隐藏提供商表选择器。模板可以使用 source_table 模板变量以列表形式访问所选值。

  • details(字典):定义用户可配置的输入字段,将值传递给模板。这是一个键/对象对的字典,每对表示一个用户可配置的 UI 元素。键是作为变量提供给 JinjaSQL 模板的任意字符串名称。 值是定义 UI 元素的对象。每个对象都具有以下字段:

    <field_name>: {
      'display_name': <string>,
      'description': <string>,
      'methodology': <string>,
      ['type': <enum>,]
      ['default': <value>,]
      ['choices': <string array>,]
      ['infoMessage': <string>,]
      ['size': <enum>]
      ['required': <bool>,]
      ['group': <string>,]
      ['references': <enum>]
      ['provider_parent_table_field':  <string>,]
      ['consumer_parent_table_field': <string>]
    }
    
    Copy
    • display_name必填):显示 UI 元素的名称

    • description必填):名称下显示的描述

    • methodology必填):说明使用者应如何使用表单执行分析

    • type:UI 元素的类型。如果为该输入字段指定了 引用,则省略该项(类型由您确定)。 支持的值:

      • any (默认):常规文本输入字段

      • boolean:真/假选择器

      • integer:使用箭头更改数字

      • multiselect:从下拉列表中选择多个项目

      • dropdown:从下拉列表中选择一个项目

      • date:日期选择器

    • default:该元素的默认值

    • choices(字符串数组) 下拉列表和多选元素选项列表

    • infoMessage:元素旁显示的信息悬停文本

    • size:元素大小。支持的值:XSSMLXL

    • required:用户是否需要某个值。指定 TRUE 或 FALSE。

    • group:组名,用于对 UI 中的项目进行分组。对 UI 中应分组在一起的项目使用相同的组名。如果隐藏默认下拉列表,则可以使用自定义模板中的 {{ source_table }}{{ my_table}} 特殊实参,然后定义自己的下拉列表,其中包含所需的表。有关在定义自定义模板时使用这些特殊变量的详细信息,请参阅 provider.add_custom_sql_template

    • references:创建一个下拉列表,其中包含 Clean Room 中可用的表或列,而无需提前了解这些表或列或单独列出这些表或列。如果使用,类型 必须是“multiselect”或“dropdown”。支持以下字符串值:

      • PROVIDER_TABLES:列出用户可访问的 Clean Room 中的所有提供商表的下拉列表。

      • PROVIDER_JOIN_POLICY:从 provider_parent_table_field 指定的提供商表中可以联接的所有列的下拉列表。

      • PROVIDER_COLUMN_POLICY:具有 provider_parent_table_field 指定的提供商表中的列策略的所有列的下拉列表。

      • CONSUMER_TABLES:列出用户可访问的 Clean Room 中的所有使用者表的下拉列表。

      • CONSUMER_COLUMNS:列出 consumer_parent_table_field 指定的使用者表中用户可以访问的所有列的下拉列表。您不应该在提供商运行的模板中使用使用者列引用,因为使用者可能会应用联接和列策略,这可能会导致在未遵守列的策略时查询失败。

      • CONSUMER_JOIN_POLICY:可以从 consumer_parent_table_field 指定的使用者表联接的所有列的下拉列表。

      • CONSUMER_COLUMN_POLICY:具有 consumer_parent_table_field 指定的使用者表中的列策略的所有列的下拉列表。

    • provider_parent_table_field:指定用户选择提供商表的 UI 元素的名称(此处不提供表名本身)。仅当 references 设置为 PROVIDER_COLUMN_POLICYPROVIDER_JOIN_POLICY 时才使用。

    • consumer_parent_table_field:指定用户选择使用者表的 UI 元素的名称(此处不提供表名本身)。仅当 references 设置为 CONSUMER_COLUMNSCONSUMER_JOIN_POLICYCONSUMER_COLUMN_POLICY 时才使用。

  • output_config(字典) 定义如何在 Web 应用程序中以图形方式显示模板结果。如果未提供,则不以图形显示结果,仅以表格显示结果。如果不需要图形,请为此实参提供一个空对象 {}。允许的字段:

    • measure_columns:包含要在 Web 应用程序生成的图形中使用的度量值和维度的列的名称。

    • default_output_type:显示结果的默认格式。如果数据格式正确,则用户通常可以更改 UI 中的显示格式。支持的类型:

      • TABLE(默认) 表格格式

      • BAR:条形图,适合比较不同类别的数据。

      • LINE:折线图,适合显示随时间变化的趋势或连续数据。

      • PIE:饼状图,适合显示比例或百分比。

返回: (字符串) 成功或失败消息。

示例:

-- Specify the display name, description, and warehouse, and hide the default table dropdown lists. 
-- Define the following two fields in the UI:
--   A provider table selector that shows all provider tables. Chosen tables can be accessed by the template with the variable 'a_provider_table'
--     (This dropdown list is equivalent to setting `render_table_dropdowns.render_provider_table_dropdown: True`)
--   A column selector for the tables chosen in 'a_provider_table'. Chosen columns can be accessed by the template with the variable 'a_provider_col'

call samooha_by_snowflake_local_db.provider.add_ui_form_customizations(
    $cleanroom_name,
    'prod_custom_template',
    {
        'display_name': 'Custom Analysis Template',
        'description': 'Use custom template to run a customized analysis.',
        'methodology': 'This custom template dynamically renders a form for you to fill out, which are then used to generate a customized analysis fitting your request.',
        'warehouse_hints': {
            'warehouse_size': 'xsmall',
            'snowpark_optimized': FALSE
        },
        'render_table_dropdowns': {
            'render_consumer_table_dropdown': false,
            'render_provider_table_dropdown': false
        },
        'activation_template_name': 'activation_my_template',
        'enabled_activations': ['consumer', 'provider']  
    },    
    {
        'a_provider_table': {
            'display_name': 'Provider table',
            'order': 3,
            'description': 'Provider table selection',
            'size': 'S',
            'group': 'Seed Audience Selection',
            'references': ['PROVIDER_TABLES'],
            'type': 'dropdown'
        },
        'a_provider_col': {
            'display_name': 'Provider column',
            'order': 4,
            'description': 'Which col do you want to count on',
            'size': 'S',
            'group': 'Seed Audience Selection',
            'references': ['PROVIDER_COLUMN_POLICY'],
            'provider_parent_table_field': 'a_provider_table',
            'type': 'dropdown'
        }
    },
    {
        'measure_columns': ['col1', 'col2'],
        'default_output_type': 'PIE'
    }
);
Copy

注册和取消注册数据

使用以下命令注册和取消注册数据库、架构和对象。必须先注册表和视图,然后才能将其链接到 Clean Room。如果您注册了一个数据库或架构,则还需注册该数据库或架构中的所有对象。

了解有关注册数据的详细信息。

provider.register_db

描述: 使数据库及其中的所有对象能够链接到此 Clean Room 环境中的单个 Clean Room。此过程将数据库的 USAGE 和 SELECT 权限授予 SAMOOHA_APP_ROLE,Clean Room 环境使用该角色访问数据。

您必须具有对数据库的 MANAGE GRANTS 访问权限才能调用此过程。然后,此 Clean Room 环境中的其他提供商可以将这些对象链接到自己的 Clean Room,而无需其 SELECT 权限。

了解有关注册数据的详细信息。

重要

此过程不会注册调用后创建的任何对象。如果向数据库中添加了新对象,并且您也希望注册这些对象,则必须再次调用此过程。

实参:

  • db_name(字符串) – 要注册的数据库的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.register_db('SAMOOHA_SAMPLE_DATABASE');
Copy

library.register_schema

描述:register_db 类似,但在架构级运行。您必须具有对架构的 MANAGE GRANTS 权限才能调用此过程。

此过程将架构的 USAGE 和 SELECT 权限授予 SAMOOHA_APP_ROLE,Clean Room 环境使用该角色访问数据。

如果要注册托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构),请改用 library.register_managed_access_schema

重要

此过程不会注册调用后创建的任何对象。如果向数据库中添加了新对象,并且您也希望注册这些对象,则必须再次调用此过程。

实参:

  • schema_name(字符串数组) – 要注册的一个或多个完全限定架构名称的数组。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_schema(['SAMOOHA_SAMPLE_DATABASE.DEMO']);
Copy

library.register_managed_access_schema

描述:register_schema 类似,但注册使用 WITH MANAGED ACCESS 参数创建的架构。您必须具有对该架构的 MANAGE GRANTS 权限才能调用此过程。

此过程将托管架构使用权限授予 SAMOOHA_APP_ROLE,Clean Room 环境使用该角色访问数据。

重要

此过程不会注册调用后创建的任何对象。如果向数据库中添加了新对象,并且您也希望注册这些对象,则必须再次调用此过程。

实参:

  • schema_name(字符串数组) – 一个或多个完全限定架构名称的数组。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_managed_access_schema(['SAMOOHA_SAMPLE_DATABASE.DEMO']);
Copy

library.register_objects

描述: 授予 Clean Room 访问所有类型的表和视图的权限,使其可以通过调用 provider.link_datasets 链接到 Clean Room。您可以通过调用 library.register_schemalibrary.register_managed_access_schemaprovider.register_db 注册更广泛的对象组。

此过程将对象使用权限授予 SAMOOHA_APP_ROLE,Clean Room 环境使用该角色访问数据。

您必须具有对对象的 MANAGE GRANTS 权限才能调用此过程。此过程不能用于注册数据库。

实参:

  • object_names(数组) – 完全限定的对象名称数组。然后可以将这些对象链接到 clean room。

返回: (字符串) 成功或失败消息。

示例

要注册表和视图:

call samooha_by_snowflake_local_db.library.register_objects(
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS','SAMOOHA_SAMPLE_DATABASE.INFORMATION_SCHEMA.FIELDS']);
Copy

library.unregister_db

描述: 颠倒 register_db 过程,并移除向 SAMOOHA_APP_ROLE 角色和 Snowflake Data Clean Room 本地应用程序授予的数据库级权限。这样还会从 Web 应用程序中的选择器中删除任何数据库。

实参:

  • db_name(字符串) – 要取消注册的数据库的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_db('SAMOOHA_SAMPLE_DATABASE');
Copy

library.unregister_schema

描述: 取消注册一个架构,以防止用户将其表和视图链接到 Clean Room。

如果要取消注册托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构),请改用 library.unregister_managed_access_schema

实参:

  • schema_name(数组) – 要取消注册的架构。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_schema(['SAMOOHA_SAMPLE_DATABASE.DEMO']);
Copy

library.unregister_managed_access_schema

描述: 类似于 unregister_schema,但取消注册了使用 WITH MANAGED ACCESS 参数创建的架构。

实参:

  • schema_name(数组) – 要取消注册的托管架构。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_managed_access_schema(['SAMOOHA_SAMPLE_DATABASE.DEMO']);
Copy

library.unregister_objects

描述: 撤销 Clean Room 对所有类型的表和视图的访问权限。此账户管理的所有 clean room 中的任何用户将无法再使用这些对象。

实参:

  • object_names(数组) – 应该撤销访问权限的完全限定对象名称数组。

返回: (字符串) 成功或失败消息。

示例

要取消注册表和视图:

call samooha_by_snowflake_local_db.library.unregister_objects(
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS','SAMOOHA_SAMPLE_DATABASE.INFORMATION_SCHEMA.FIELDS']);
Copy

管理联接策略

Data Clean Room 中的联接策略与 Snowflake 全域联接策略 不同。仅使用此过程设置 Clean Room 的联接策略;Clean Room 会忽略在 Clean Room 之外的表上设置的联接策略。

provider.view_join_policy

说明: 显示当前应用于 Clean Room 的联接策略。

实参:

  • cleanroom_name(字符串) – 要查询的 Clean Room 的名称。

返回: (表) Clean Room 中所有表或视图的可联接行列表。

示例:

call samooha_by_snowflake_local_db.provider.view_join_policy($cleanroom_name);
Copy

provider.set_join_policy

描述: 指定在此 Clean Room 内运行模板时,使用者可以联接哪些列。注意,联接策略是 仅替换,因此如果再次调用过程,新的联接策略会完全替换之前设置的联接策略。

重要

只有 当模板应用 join_policyjoin_and_column_policy JinjaSQL 筛选器来联接行时,才会强制实施联接策略。

备注

Data Clean Room 中的联接策略与 Snowflake 全域联接策略不同。仅使用此过程设置 Clean Room 的联接策略;Clean Room 会忽略在 Clean Room 之外的表上设置的联接策略。

实参:

  • cleanroom_name(字符串) – 应强制实施联接策略的 Clean Room 的名称。

  • table_and_col_names(字符串数组) – 完全限定的列名,格式为 database_name.schema_name.table_or_view_name:column_name。** 注意正确使用 . versus : 标记**

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.set_join_policy($cleanroom_name, ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:EMAIL', 'SAMOOHA_SAMPLE_DATABASE.DEMO.EXPOSURES:EMAIL']);
Copy

管理提供商模板

使用以下命令添加此 Clean Room 支持的模板/分析。

provider.view_added_templates

描述: 查看 Clean Room 中提供商添加的模板。没有为此提供商列出所有 Clean Room 中所有模板的方法。

实参:

  • cleanroom_name(字符串) – 要查询的 Clean Room。

返回: (表) – 指定 Clean Room 中可用的模板列表,含每个模板的详细信息。

示例:

call samooha_by_snowflake_local_db.provider.view_added_templates($cleanroom_name);
Copy

provider.view_template_definition

描述: 显示有关特定模板的信息。查看提供商模板的使用者应使用 consumer.view_template_Definition

实参:

  • cleanroom_name(字符串) – 具有此模板的 Clean Room 的名称。

  • template_name(字符串) – 要请求相关信息的模板的名称。

返回: 模板定义(字符串)

示例:

call samooha_by_snowflake_local_db.provider.view_template_definition($cleanroom_name, 'prod_overlap_analysis');
Copy

provider.add_templates

**描述:**向 Clean Room 添加模板列表。这不会取代现有的模板列表。

实参:

  • cleanroom_name(字符串) – 要添加模板的 Clean Room 的名称。

  • template_names(字符串数组)) – 要添加的模板的名称。这些只是 Snowflake 提供的模板。要添加自定义模板,请调用 add_custom_sql_template。Snowflake 提供的模板名称包括“prod_overlap_analysis”和“prod_provider_data_analysis”。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.add_templates($cleanroom_name, ['prod_overlap_analysis']);
Copy

provider.clear_template

描述: 从 Clean Room 中移除指定模板。

实参:

  • cleanroom_name(字符串) – Clean Room 的名称。

  • template_name(字符串) – 要从 Clean Room 中移除的模板的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.clear_template($cleanroom_name, 'prod_custom_template');
Copy

provider.clear_all_templates

描述: 移除已添加到 Clean Room 的所有模板。

实参:

  • cleanroom_name(字符串) – 要从中移除所有模板的 Clean Room 的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.clear_all_templates($cleanroom_name);
Copy

provider.set_column_policy

描述: 将数据中的哪些列设置为作为非联接行对 Clean Room 中的指定模板可用。必须在此处或者在 set_join_policy 中声明列后,才能在 Clean Room 中使用。此处列出的列可用于模板中的任何位置,但用作联接列除外。列不能同时列在列策略和联接策略中。

默认情况下,表的列策略为空,这意味着在结果中看不到任何列。

此过程是 完全替换 行为,因此每次调用时,都会完全覆盖前面的列列表。

请注意,进行列策略检查的方式是解析为查找任何未经授权的列而要对数据运行的 SQL 查询。使用这些检查可能无法捕获带有通配符的查询,在设计分析模板时应谨慎行事。如果某些列确实不应该被查询,可以考虑创建源表的视图来消除这些敏感列,并链接该视图。

实参:

  • cleanroom_name(字符串) – Clean Room 的名称。

  • analysis_and_table_and_cols(字符串数组) – 模板可以使用的列数组。格式为:template_name:full_table_name:column_name

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.set_column_policy($cleanroom_name,
['prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:STATUS',
 'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:AGE_BAND',
 'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:DAYS_ACTIVE']);

 -- Same example, but using a variable name for the template.
call samooha_by_snowflake_local_db.provider.set_column_policy($cleanroom_name,
[$template_name || ':SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:STATUS',
 $template_name || ':SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:AGE_BAND',
 $template_name || ':SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:DAYS_ACTIVE']);
Copy

provider.view_column_policy

描述: 列出当前在 Clean Room 中活动的列策略。列策略说明哪些表列可以在哪些模板中显示。

实参: cleanroom_name(字符串)

返回: (表) 哪些列可用于哪些模板。

示例:

call samooha_by_snowflake_local_db.provider.view_column_policy($cleanroom_name);
Copy

provider.add_custom_sql_template

描述: 将自定义 JinjaSQL 模板添加到 Clean Room。这样的话,使用者就可以调用模板了。

您可以多次调用该 API 将多个自定义模板添加到 Clean Room。该过程会覆盖此 Clean Room 中之前的同名模板。

如果使用者使用模板 将结果返回给提供商,则命令必须满足以下要求:

  • 自定义模板的名称必须以字符串 activation 开头。例如,activation_custom_template

  • 模板必须创建以 cleanroom.activation_data_ 开头的表。 例如,CREATE TABLE cleanroom.activation_data_analysis_results AS ...

  • 模板必须返回在定义(即追加到 cleanroom.activation_data_ 的字符串)中创建的表名的唯一部分。例如,return 'data_analysis_results'

JinjaSQL 模板可以访问两个全局变量:

  • source_table:提供商表数组。当使用 Web 应用程序运行模板时,这些模板由使用者使用 Web 表单选择。使用代码运行模板时,将使用 provider_tables 实参将代码传递给 consumer.run_analysis

  • my_table:使用者表数组。当使用 Web 应用程序运行模板时,这些模板由使用者使用 Web 表单选择。使用代码运行模板时,将使用 consumer_tables 实参将代码传递给 consumer.run_analysis

必须使用这些实参来引用所有提供商/使用者表,因为实际链接到 Clean Room 的安全视图名称与表名不同。重要的是,提供商表别名 MUST 为 p(或 p1)、p2、p3、p4 等。使用者表别名 必须 为 c(或 c1)、c2、c3 等。要在 Clean Room 中执行安全策略,必须满足此条件。

应使用以下筛选器检查自定义 JinjaSQL 模板中的所有用户指定列是否符合联接策略和列策略:

  • join_policy:检查字符串值或筛选器子句是否符合联接策略

  • column_policy:检查字符串值或筛选器子句是否符合列策略

  • join_and_column_policy:检查筛选器子句中用于联接的列是否符合联接策略,以及用作筛选器的列是否符合列策略

例如,在子句 {{ where_clause | sqlsafe | join_and_column_policy }} 中,将解析 where_clause = 'p.HEM = c.HEM and p.STATUS = 1' 的输入,以检查 p.HEM 是否在联接策略中,以及 p.STATUS 是否在列策略中。

注意:请谨慎使用 sqlsafe 筛选器,因为它允许协作者将纯 SQL 放入模板。

实参:

  • cleanroom_name(字符串) – 适用此模板的 Clean Room 的名称。

  • template_name(字符串) – 模板的名称。必须全部是小写字母、数字、空格或下划线。激活模板的名称必须以“activation”开头。

  • 模板(字符串) – JinjaSQL 模板。

  • sensitivity(浮点数,可选) – 如果为该 Clean Room 启用了差分隐私,则它会指定应用于该模板使用的数据的差分隐私噪声量。默认值为 1.0,没有上限。将此值设置为查询可以通过从结果中排除单行而更改的最大量。必须在此 Clean Room 中启用差分隐私,此实参才能生效。

  • consumer_locators(字符串数组,可选) – 一个或多个账户定位器的数组。如果存在,此模板将仅添加到这些账户的 Clean Room。您可以稍后通过调用 provider.restrict_template_options_to_consumers 来修改此列表。如果未指定使用者列表,则所有使用者都可以在指定的 Clean Room 中使用自定义模板。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.add_custom_sql_template(
    $cleanroom_name, 'prod_custom_template', 
    $$
select 
    identifier({{ dimensions[0] | column_policy }}) 
from 
    identifier({{ my_table[0] }}) c 
    inner join 
    identifier({{ source_table[0] }}) p 
    on 
        c.identifier({{ consumer_id  }}) = identifier({{ provider_id | join_policy }}) 
    {% if where_clause %} where {{ where_clause | sqlsafe | join_and_column_policy }} {% endif %};
    $$);
Copy

provider.restrict_template_options_to_consumers

描述: 控制哪些用户可以访问给定 Clean Room 中的给定模板。此过程将覆盖之前由任何其他过程为 Clean Room/模板对指定的任何访问列表。

实参:

  • cleanroom_name(字符串) – Clean Room 的名称。

  • access_details(JSON 对象) – 模板的名称以及可以在该 Clean Room 中访问该模板的用户。如果指定了模板,则只有此处列出的用户才能在该 Clean Room 中访问该模板。这是一个对象,每个模板有一个子对象,格式如下:{'template_name': ['user1_locator','user2_locator','userN_locator']}

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.restrict_template_options_to_consumers(
    $cleanroom_name,
    {
        'prod_template_1': ['CONSUMER_1_LOCATOR', 'CONSUMER_2_LOCATOR']
    }
);
Copy

使用者自定义模板

以下 APIs 让您可以批准或拒绝使用者为 Clean Room 添加模板的请求。仅当提供商批准使用者添加模板的请求时,才会将使用者定义的模板添加到 Clean Room。有关更多信息,请参阅 使用开发者 API 添加使用者定义的模板

provider.list_template_requests

描述: 列出所有想要将使用者定义的模板添加到 Clean Room 的使用者的请求。其中包括待处理、已批准和已拒绝的请求。使用此选项可检查待处理请求并审批 (provider.approve_template_request) 或拒绝 (provider.reject_template_request) 它们。

重要

在调用此过程之前,您必须在 Clean Room 内调用一次 provider.mount_request_logs_for_all_consumers。无需多次调用

实参:

  • cleanroom_name(字符串) – 查看使用者要求向此 Clean Room 添加模板的请求。

返回: 包含以下值的表:

request_id(字符串) – 请求的 ID,接受或拒绝请求需要使用。consumer_identifier(字符串) – 提出请求者的账户定位器。template_name(字符串) – 使用者提供的模板的名称。template_definition(字符串) – 使用者建议的模板的完整定义。status(字符串) – 请求的状态:PENDING、APPROVED、REJECTED。

示例:

call samooha_by_snowflake_local_db.provider.list_template_requests($template_name);
Copy

provider.approve_template_request

描述: 批准为 Clean Room 添加模板的请求。

实参:

  • cleanroom_name(字符串) – 用户要添加模板的 Clean Room 的名称。

  • request_id(字符串) – 要批准的请求的 ID。调用 provider.list_template_requests 查看请求 IDs。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.approve_template_request('dcr_cleanroom', 
    '01b4d41d-0001-b572');
Copy

provider.reject_template_request

描述:拒绝为 Clean Room 添加模板的请求。

实参:

  • cleanroom_name(字符串) – 用户要添加模板的 Clean Room 的名称。

  • request_id(字符串) – 要拒绝的请求的 ID。调用 provider.list_template_requests 查看请求 IDs。

  • reason_for_rejection(字符串) – 拒绝请求的原因。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.reject_template_request('dcr_cleanroom',
  '01b4d41d-0001-b572',
  'Failed security assessment');
Copy

模板链

使用以下命令创建和管理 模板链

provider.add_template_chain

描述: 创建新的模板链。模板在添加到模板链之前必须存在。创建模板链后,将无法修改,但您可以创建一个同名的新模板链以覆盖旧模板链。

实参:

  • cleanroom_name(字符串) – 应添加模板链的 Clean Room 的名称。

  • template_chain_name(字符串) – 模板链的名称。

  • templates(对象数组) – 对象数组,每个模板一个。对象可能包含以下字段:

    • template_name(字符串)– 指定要添加到模板链的模板。模板必须已经通过调用 provider.add_template_chain 添加到 Clean Room。

    • cache_results(布尔)– 确定模板的结果是否临时保存,以便模板链中的其他模板可以访问这些结果。要缓存结果,请指定 TRUE。

    • output_table_name(字符串)– 如果 cache_results = TRUE,则指定存储模板结果的 Snowflake 表的名称。

    • jinja_output_table_param(字符串)– 如果 cache_results = TRUE,则指定其他模板必须包括的 Jinja 参数的名称,以接受 output_table_name 中存储的结果。

    • cache_expiration_hours(整型)– 如果 cache_results = TRUE,则指定删除缓存中结果之前的小时数。当缓存过期时,那么下次执行模板链时,缓存会使用模板的结果刷新。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.add_template_chain(
  $cleanroom_name,
  'my_chain',
  [
    {
      'template_name': 'crosswalk',
      'cache_results': True,
      'output_table_name': 'crosswalk',
      'jinja_output_table_param': 'crosswalk_table_name',
      'cache_expiration_hours': 2190
    },
    {
      'template_name': 'transaction_insights',
      'cache_results': False
    }
  ]
);
Copy

provider.view_added_template_chains

描述: 列出指定 Clean Room 中的模板链。

实参:

  • cleanroom_name(字符串) – Clean Room 的名称。

返回: (表) 添加到此 Clean Room 的所有模板链的描述。

示例:

call samooha_by_snowflake_local_db.provider.view_added_template_chains($cleanroom_name);
Copy

provider.view_template_chain_definition

描述: 返回模板链的定义。

实参:

  • cleanroom_name(字符串) – 与此模板链关联的 Clean Room 的名称。

  • template_chain_name(字符串) – 与此 Clean Room 关联的模板链的名称。

返回: (表) 指定模板链的描述。

示例:

call samooha_by_snowflake_local_db.provider.view_template_chain_definition($cleanroom_name, 'my_chain');
Copy

provider.clear_template_chain

**描述:**从指定的 Clean Room 删除指定的模板链。链不会存储在任何位置,因此如果要重新创建链,则必须从头开始重新创建。

实参:

  • *cleanroom_name(字符串) – 分配给此模板链的 Clean Room。

  • template_chain_name(字符串) – 要从此 Clean Room 移除的模板链。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.clear_template_chain($cleanroom_name, 'my_chain');
Copy

provider.clear_all_template_chains

描述: 从指定的 Clean Room 删除所有模板链。

实参:

  • cleanroom_name(字符串) – 要从中删除所有模板链的 Clean Room 的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.clear_all_template_chains($cleanroom_name);
Copy

多提供商分析

这些过程可实现 多供应商分析

provider.enable_multiprovider_computation

描述: 此过程使来自多个 Snowflake Clean Room 但可能属于不同提供商的表,可以由使用者提供的单一模板使用。指定哪些 Clean Room 可以与哪些其他用户查询的其他 Clean Room 一起查询。

实参:

  • cleanroom_name(字符串) – 您拥有的 Clean Room 的名称。当下列用户提出请求时,此 Clean Room 中的所有数据都可以与下列其他 Clean Room 共享。

  • consumer_account(字符串) – 可以提出请求的使用者的账户定位器,如果获得批准,则结合 approved_other_cleanroom 中列出的任何 Clean Room 的数据,针对此 Clean Room 中的任何表运行查询。

  • approved_other_cleanrooms(字符串数组) – 完全限定 Clean Room 名称数组,此 Clean Room 的数据可以与之组合。每个条目的格式均为 provider_org_name.provider_account_name.cleanroom_name

返回: (字符串) 成功或失败消息。

示例:

CALL samooha_by_snowflake_local_db.provider.enable_multiprovider_computation(
  $cleanroom_name,
  $consumer_account_locator,
  'org1.account123',
  $cleanroom_name_2);
Copy

provider.process_multiprovider_request

描述: 评估使用者发送的多 Clean Room 查询请求。基于以下因素评估请求:请求年限,以及请求者和 Clean Room 是否列在以前的 provider.enable_multiprovider_computation 调用中。通过评估的请求获得批准。

默认情况下,必须使用此过程处理所有多提供商请求。如果希望自动处理请求,请调用 provider.resume_multiprovider_tasks

评估请求后,将请求和评估状态写入

samp:

samooha_cleanroom_${CLEANROOM_NAME}.admin.request_log_multiprovider 表(如果通过评估,则请求获得批准)。您可以通过查询该表来查看请求和评估状态的列表:

SELECT * FROM samooha_cleanroom_Samooha_Cleanroom_Multiprovider_Clean_Room_1.admin.request_log_multiprovider;
Copy

批准的请求允许同一使用者对同一数据运行相同的查询,次数不限。如果以后要撤销权限,则必须在日志记录表中将已批准状态设置为 FALSE:

UPDATE samooha_cleanroom_Samooha_Cleanroom_Multiprovider_Clean_Room_1.admin.request_log_multiprovider SET APPROVED=False WHERE <CONDITIONS>;
Copy

实参:

  • *cleanroom_name(字符串) – 使用者要求将其包含在多提供商分析中的 Clean Room 的名称。

  • consumer_account(字符串) – 请求多提供商分析的用户的使用者账户定位器。此定位器必须已获批准用于此 Clean Room 和在调用 provider.enable_multiprovider_computation 的请求中列出的其他 Clean Room。

  • request_id(字符串) – 要批准的请求 ID,来自 provider.view_multiprovider_requests。或者,传入“-1”以批准所有待定的请求。用以前处理过的请求调用此函数将会失败。

返回: (字符串) 成功或失败消息。

示例:

CALL samooha_by_snowflake_local_db.provider.process_multiprovider_request($cleanroom_name_1, $consumer_account_locator, $request_id);
Copy

provider.view_multiprovider_requests

描述: 显示来自给定账户和 Clean Room 的所有多提供商分析请求。

实参:

  • *cleanroom_name(字符串) – 显示涉及此 Clean Room 的请求。

  • consumer_account(字符串) – 显示来自此使用者账户的请求。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.process_multiprovider_request('my_cleanroom', [ 
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:HASHED_EMAIL',  
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:REGION_CODE' ]);
Copy

provider.suspend_multiprovider_tasks

描述:

实参:

  • cleanroom_name(字符串)

  • consumer_account(字符串)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.process_multiprovider_request('my_cleanroom', [ 
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:HASHED_EMAIL',  
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:REGION_CODE' ]);
Copy

provider.resume_multiprovider_tasks

描述:

实参:

  • cleanroom_name(字符串)

  • consumer_account(字符串)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.process_multiprovider_request('my_cleanroom', [ 
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:HASHED_EMAIL',  
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:REGION_CODE' ]);
Copy

提供商激活

激活 意味着将结果导出到提供商、使用者或第三方。阅读更多关于激活的信息。

provider.set_activation_policy

描述: 定义哪些列可以在激活模板中使用。确保只有提供商批准的列可以与激活模板一起使用。

实参:

  • cleanroom_name(字符串) – 应允许激活的 Clean Room 的名称。

  • columns(字符串数组) – 只有此处列出的列才能用于此 Clean Room 的激活模板。列名称格式为 template_name:fully_qualified_table_name:column_name注意正确使用点 . 和冒号 : 标记。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.set_activation_policy('my_cleanroom', [ 
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:HASHED_EMAIL',  
    'prod_overlap_analysis:SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS:REGION_CODE' ]);
Copy

以提供商身份运行分析

了解如何运行提供商分析。

provider.enable_provider_run_analysis

描述: 使提供商(Clean Room 创建者)能够在指定 Clean Room 中运行分析。此功能默认禁用。提供商仍必须通过调用 provider.submit_analysis_request 来通过每个分析的自动安全检查。

了解更多有关提供商运行分析的信息。

重要

此过程必须在 provider.add_consumers 之后、使用者安装 Clean Room 之前调用。如果使用者在安装 Clean Room 后更改了此配置,则必须重新安装 Clean Room 以反映新的配置。

实参:

  • *cleanroom_name(字符串) – 应启用提供商运行分析的 Clean Room 的名称。

  • consumer_accounts(字符串数组) – 所有向此 Clean Room 添加数据的使用者账户的账户定位器。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.enable_provider_run_analysis($cleanroom_name, ['<CONSUMER_ACCOUNT_LOCATOR>']);
Copy

provider.disable_provider_run_analysis

描述: 阻止提供商(Clean Room 创建者)在 Clean Room 中运行分析(默认已禁用)。

重要

此过程必须在 provider.add_consumers 之后、使用者安装 Clean Room 之前调用。如果用户在安装 Clean Room 后更改了此配置,则需要重新安装 Clean Room 以反映新的配置。

实参:

  • *cleanroom_name(字符串) – 应禁用提供商运行分析的 Clean Room 的名称。

  • consumer_account_locator(字符串) – 传递给 provider.enable_provider_run_analysis 的相同使用者账户名称列表。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.disable_provider_run_analysis($cleanroom_name, ['<CONSUMER_ACCOUNT_LOCATOR>']);
Copy

library.is_provider_run_enabled

描述: 检查此 Clean Room 是否允许提供商运行分析。

实参:

  • cleanroom_name(字符串) – 要检查的 Clean Room 的名称。

返回: (字符串) 此 Clean Room 是否允许提供商运行分析。

示例:

call samooha_by_snowflake_local_db.library.is_provider_run_enabled($cleanroom_name)
Copy

provider.submit_analysis_request

描述: 请求使用者许可在指定的 Clean Room 中运行指定的模板。调用此过程之前,必须满足以下所有条件:

模板在 Clean Room 内运行,结果安全地存储在 Clean Room 内。结果已加密,因此只有提供商可以看到结果。

实参:

  • cleanroom_name(字符串) – 应在其中运行模板的 Clean Room 的名称。

  • consumer_account_locator(字符串) – 此 Clean Room 中允许通过调用 consumer.enable_templates_for_provider_run 进行提供商运行分析的使用者的账户定位器。

  • template_name(字符串) – 要运行的模板的名称。

  • provider_tables(数组) – 要提供给模板的提供商表列表。此列表将填充 source_table 数组变量。

  • consumer_tables(数组) – 要提供给模板的使用者表列表。此列表将填充 my_table 数组变量。

  • analysis_arguments(对象) – JSON 对象,其中每个键都是您创建的模板中使用的实参名称。

返回: (字符串) 用于检查请求状态以及访问结果的请求 ID。保存此 ID,因为您将需要使用它来查看分析结果。

示例:

call samooha_by_snowflake_local_db.provider.submit_analysis_request(
    $cleanroom_name, 
    '<CONSUMER_ACCOUNT>',
    'prod_overlap_analysis', 
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS'], 
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS'], 
    object_construct(       
      'dimensions', ['c.REGION_CODE'],        
      'measure_type', ['AVG'],           
      'measure_column', ['c.DAYS_ACTIVE']                                         
    ));
Copy

provider.check_analysis_status

描述: 提供商调用此过程以检查提供商分析请求的状态。在开始查看请求状态之前,可能会有相当长的延迟。当分析标记为完成后,调用 provider.get_analysis_result 可查看结果。

实参:

  • cleanroom_name(字符串) – 在其中提出请求的 Clean Room 的名称。

  • request_id(字符串) – 由 provider.submit_analysis_request 返回的请求的 ID。

  • consumer_account_locator(字符串) – 向其发送请求的使用者的账户定位器。

返回: (字符串) 请求的状态,其中 COMPLETED 表示成功完成分析。

示例:

-- It can take up to 2 minutes for this to pick up the request ID after the initial request
call samooha_by_snowflake_local_db.provider.check_analysis_status(
    $cleanroom_name, 
    $request_id, 
    '<CONSUMER_ACCOUNT>'
);
Copy

provider.get_analysis_result

描述: 获取提供商运行分析的结果。您必须等到分析状态列为 COMPLETED 后才能得到结果。结果在 Clean Room 无限期存在。

实参:

  • cleanroom_name(字符串) – 向其发送请求的 Clean Room 的名称。

  • request_id(字符串) – 由 submit_analysis_request 返回的请求的 ID。

  • consumer_account_locator(字符串) – 传递到 submit_analysis_request 中的使用者的账户定位器。

返回: (表) 查询结果。

示例:

call samooha_by_snowflake_local_db.provider.get_analysis_result(
    $cleanroom_name, 
    $request_id, 
    $locator
);
Copy

管理 Clean Room 共享

使用以下命令,管理与使用者共享 Clean Room。

provider.view_consumers

描述: 列出获准访问 Clean Room 的使用者。它不会显示使用者是否已安装 Clean Room。

实参:

  • cleanroom_name(字符串) – 关注的 Clean Room。

返回: (表) – 可以访问 Clean Room 的使用者账户列表。

示例:

call samooha_by_snowflake_local_db.provider.view_consumers($cleanroom_name);
Copy

provider.add_consumers

描述: 授予指定用户访问指定 Clean Room 的权限。Clean Room 可以通过 Web 应用程序和 API 访问。此操作不会覆盖以前调用的使用者列表。Clean Room 访问权限授予特定用户,而不是整个账户。请注意,使用者账户必须与提供商位于同一 Snowflake 区域,才能访问 Clean Room。您可以通过调用 select current_region(); 来检查您所在的区域

您可以通过调用 provider.view_consumers 来查看当前的使用者列表。

实参:

  • cleanroom_name(字符串) – 要与指定用户共享的 Clean Room 的名称。用户可以使用 API 或 Web 应用程序安装 Clean Room。

  • consumer_account_locators(字符串) – 由 CURRENT_ACCOUNT 返回的,以逗号分隔的使用者账户定位器列表。此列表应包含与 consumer_account_names 中数量相同、顺序相同的条目。

  • consumer_account_names(字符串) – 可通过调用 CURRENT_ORGANIZATION_NAME 检索的,格式为 org_name.account_name Org name,以逗号分隔的使用者账户名称列表。可以通过调用 CURRENT_ACCOUNT_NAME 来检索账户名称。此列表应包含与 consumer_account_locators 中列出的数量相同、顺序相同的条目。

  • enable_differential_privacy_tasks(布尔,可选,默认值:FALSE) – 是否对此 Clean Room 中列出的用户启用差分隐私。必须为此 Clean Room 启用差分隐私才能指定 TRUE。

返回: (字符串) 成功或失败消息。请注意,该过程不会验证用户定位器或账户名称,因此成功仅表示提交的定位器已添加到此 Clean Room 的数据库。

示例 1

call samooha_by_snowflake_local_db.provider.add_consumers($cleanroom_name, 'LOCATOR1,LOCATOR2', 'ORG1.NAME1,ORG2.NAME2');
Copy

provider.remove_consumers

描述: 删除对给定 Clean Room 的账户访问权限。此方法可阻止提供账户中的所有用户访问。

您可以通过调用 provider.view_consumers 来查看当前的使用者列表。

实参:

  • cleanroom_name(字符串) – Clean Room 的 ID(不容易记住的名称)。

  • cleanroom_account_locators(字符串) – 以逗号分隔的用户账户定位器列表。账户中的所有用户都将无法访问 Clean Room。

返回: (字符串) – 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.remove_consumers($cleanroom_name, 'locator1,locator2,locator3');
Copy

provider.set_cleanroom_ui_accessibility

描述: 向所有登录此提供商账户登录的用户显示或隐藏 Web 应用程序中的 Clean Room。

实参:

  • cleanroom_name(字符串) – Clean Room 的名称。

  • visibility_status(字符串) – 以下区分大小写的值之一:

    • HIDDEN – 对当前提供商账户中的所有用户隐藏 Web 应用程序中的 Clean Room。Clean Room 仍可通过 API 调用访问。

    • EDITABLE – 让 clean room 在 Web 应用程序中可见。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.set_cleanroom_ui_accessibility($cleanroom_name, 'HIDDEN');
Copy

provider.enable_laf_for_cleanroom

描述: 启用 Cross-Cloud Auto-Fulfillment,允许您在协作者的 Snowflake 账户与提供商的账户位于不同区域时与协作者共享 Clean Room。Cross-Cloud Auto-Fulfillment 也称为 Listing Auto-Fulfillment (LAF)。

默认情况下,对于新 Clean Room,Cross-Cloud Auto-Fulfillment 是关闭的,即使该环境已启用。

重要

在执行此命令 之前,必须由具有 ACCOUNTADMIN 角色的 Snowflake 管理员在您的 Snowflake 账户中启用 Cross-Cloud Auto-Fulfillment。有关在 Snowflake 账户中启用 Cross-Cloud Auto-Fulfillment 的说明,请参阅 与不同区域的账户协作

与其他区域的使用者协作会产生额外费用。有关这些费用的更多信息,请参阅 Cross-Cloud Auto-Fulfillment 费用

实参:

*cleanroom_name(字符串) – 应跨区域共享的 Clean Room 的名称。管理员必须为账户启用 Cross-Cloud Auto-Fulfillment,然后才能共享单个 Clean Room。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.enable_laf_for_cleanroom($cleanroom_name);
Copy

library.is_laf_enabled_on_account

描述: 返回是否为此账户启用 Cross-Cloud Auto-Fulfillment。

返回: 如果为此账户启用了 Cross-Cloud Auto-Fulfillment,则为 TRUE,否则为 FALSE。

示例:

call samooha_by_snowflake_local_db.library.is_laf_enabled_on_account();
Copy

在 Clean Room 中使用 Python

provider.load_python_into_cleanroom

描述: 将自定义 Python 函数加载到 Clean Room。使用此过程加载到 Clean Room 的代码都对使用者不可见。Jinja 模板可以调用上传的代码。

了解如何在 Clean Room 中上传和使用 Python 代码。

此过程会递增 Clean Room 的补丁号并触发安全扫描。您必须等待扫描状态变为 APPROVED,然后才能与协作者共享最新版本。

此过程重载,并且具有两个签名,该签名与第五个实参的数据类型不同,它们决定了是内联上传代码还是从暂存区上的文件加载代码:

签名

内联 UDF 上传:

(cleanroom_name String, function_name String, arguments Array, packages Array, rettype String, handler String, code String)
Copy

从暂存区上传 UDF:

(cleanroom_name String, function_name String, arguments Array, packages Array, imports Array, rettype String, handler String)
Copy

实参:

  • cleanroom_name(字符串) – 应在其中加载脚本的 Clean Room 的名称。

  • function_name(字符串) – 此包的名称。在自定义模板中使用此名称可以使用 实参 描述的任何实参调用 处理程序 指定的函数。

  • arguments(字符串对数组) – 函数 function_name 所需的实参数组。每个实参都是一对以空格分隔的字符串,带有实参名称和实参 SQL 数据类型。此条目用于用户文档,不会进行验证。例如:'size integer'、'month string'、'data variant'。。

  • packages(字符串数组) – 代码使用的 Python 包名称列表。这些必须是标准 Python 包;您的 UDFs 不能调用其他上传的 UDFs。

  • imports(具有单个元素的字符串数组) – 仅在从暂存区上传 UDF 时存在。这是一个具有单个元素的字符串数组:相对于您上传代码的暂存区的暂存区地址。根暂存区路径可通过调用 provider.get_stage_for_python_files 获得。

  • ret_type(字符串) – 函数 处理程序 返回的值的 SQL 数据类型。例如:“整型”、“变体”。

  • handler(字符串) – 当模板调用 function_name 时应调用的代码中的入口点函数。

    • 对于内联 UDF,这是函数的名称,例如:main

    • 对于从暂存区上传的代码,这是源文件名限定的函数名称,例如:myscript.main

  • code(字符串) – 仅在以内联代码形式上传 UDF 时存在。这应该是一个 Python UDF。

返回: (字符串) 成功或失败消息。

示例:

-- Inline UDF

call samooha_by_snowflake_local_db.provider.load_python_into_cleanroom(
    $cleanroom_name, 
    'assign_group',                      # Name of the UDF
    ['data variant', 'index integer'],   # Arguments of the UDF, along with their type
    ['pandas', 'numpy'],                 # Packages UDF will use
    'integer',                           # Return type of UDF
    'main',                              # Handler
    $$
import pandas as pd
import numpy as np

def main(data, index):
    df = pd.DataFrame(data)  # you can do something with df but this is just an example
    return np.random.randint(1, 100)
    $$
);
Copy
-- Upload from stage

call samooha_by_snowflake_local_db.provider.load_python_into_cleanroom(
    $cleanroom_name,
    'myfunc',                            # Name of the UDF
    ['data variant', 'index integer'],   # Arguments of the UDF
    ['numpy', 'pandas'],                 # Packages UDF will use
    ['/test_folder/assign_group.py'],    # Python file to import from a stage
    'integer',                           # Return type of UDF
    'assign_group.main'                  # Handler scoped to file name
);
Copy

provider.get_stage_for_python_files

描述: 如果您计划使用上传到暂存区的代码文件而不是内联代码定义来定义 Clean Room 中的自定义 Python 代码,则返回应将 Python 文件上传到的暂存区路径。在通过调用 provider.load_python_into_cleanroom 上传文件之前,该暂存区不存在,无法检查。

了解如何在 Clean Room 中上传和使用 Python 代码。

实参:

  • cleanroom_name(字符串) – 要向其中上传文件的 Clean Room 的名称。

返回: (字符串) 您应该上传代码文件的路径。将其用于 provider.load_python_into_cleanroom 中的 imports 实参。

示例:

call samooha_by_snowflake_local_db.provider.get_stage_for_python_files($cleanroom_name);
Copy

provider.view_cleanrooom_scan_status

描述: 报告 DISTRIBUTION 设置为 EXTERNAL 的 Clean Room 的威胁扫描状态。扫描需要标记为“APPROVED:”,然后才能设置或更改默认发布指令。扫描状态只需要用 EXTERNAL Clean Room 检查。

实参:

  • cleanroom_name(字符串) – 要检查状态的 Clean Room 的名称。

返回: (字符串) 扫描状态。

示例:

call samooha_by_snowflake_local_db.provider.view_cleanroom_scan_status($cleanroom_name);
Copy

Clean Room 元数据 getter 命令

使用以下命令可显示 Clean Room 的相关属性。

provider.mount_request_logs_for_all_consumers

描述: 让提供商能够访问 Clean Room 使用者返回给提供商的信息。

.. # TODO:需要相关详细信息,哪些日志需要先调用此函数?)

实参:

  • cleanroom_name(字符串) – 要挂载请求日志的 Clean Room 的名称。

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.mount_request_logs_for_all_consumers($cleanroom_name);
Copy

provider.view_request_logs

描述: 查看此 Clean Room 的使用者正在发送的请求日志。在首次调用此函数前,您必须先调用 mount_request_logs_for_all_consumers

.. # TODO:记录哪些请求?)

实参:

  • cleanroom_name(字符串) – 要查看请求日志的 Clean Room 的名称。

返回: 针对 Clean Room 运行的查询的一系列日志(表)

示例:

call samooha_by_snowflake_local_db.provider.view_request_logs($cleanroom_name);
Copy

差分隐私

这些命令控制 Clean Room 中的差分隐私。您还可以在调用 provider.add_custom_sql_templateprovider.add_consumers 时在模板或使用者级别指定差分隐私。

provider.is_dp_enabled_on_account

描述: 描述是否为此账户启用了差分隐私。

实参:

返回: 如果对此账户启用了差分隐私,则为 TRUE,否则为 FALSE。

示例:

call samooha_by_snowflake_local_db.provider.is_dp_enabled_on_account();
Copy

provider.suspend_account_dp_task

描述: 禁用侦听差分隐私信号的任务。此函数用于控制 账户中与差分隐私相关的成本。如果差分隐私任务被禁用,差分隐私可能会也可能不会在任何指定了差分隐私的现有模板中继续运行,尽管您不会因为差分隐私承担费用。了解有关管理差分隐私的详细信息。

实参:

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.suspend_account_dp_task();
Copy

provider.resume_account_dp_task

描述: 在当前账户中恢复差分隐私任务侦听器。具有差分隐私的模板将重新开始发挥作用。之前设置的任何差分隐私值(如敏感度或关联用户)都将保留。

实参:

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.resume_account_dp_task();
Copy

常规 helper 命令

使用以下命令一般有助于充分利用 Clean Room 功能和支持流程。

library.enable_local_db_auto_upgrades

描述: 启用任务 samooha_by_snowflake_local_db.admin.expected_version_task,以在新版本发布时自动升级 Snowflake Data Clean Rooms Native App。虽然您可能会通过禁用此任务来降低成本,但我们建议保持其运行,以确保系统上的 Clean Rooms Native App 始终为最新版本。

实参:

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.enable_local_db_auto_upgrades();
Copy

library.disable_local_db_auto_upgrades

描述:禁用任务 samooha_by_snowflake_local_db.admin.expected_version_task,该任务会在新版本发布时自动升级 Snowflake Data Clean Rooms Native App。

实参:

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.disable_local_db_auto_upgrades();
Copy

已弃用的过程

下列过程已弃用,在此处列出仅为保障列表完整性。如果指明了替换过程,请使用较新的过程。

provider.view_ui_registration_request_log -- DEPRECATED

注意

此命令现已弃用。 您不再需要手动注册 Clean Room 模板以在 Web 应用程序中使用。

描述: 查看从账户提出的将 Clean Room 注册到 Web 应用程序的请求的列表。每个请求都有关联的 ID,可与 view_ui_registration_log 程序结合使用,以查看请求的状态。请求共享到后端,在此处处理请求,并将 Clean Room 添加到 Clean Room。

实参:

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.view_ui_registration_request_log();
Copy

library.register_table_or_view – 已弃用

注意

此命令现已弃用。 改用 library.register_objects

描述: 注册所有类型的表和视图。

实参: object_names(数组)、is_view(布尔)、is_iceberg(布尔)、is_external(布尔)、is_under_managed_access_schema(布尔)

返回: (字符串) 成功或失败消息。

示例

要注册表:

call samooha_by_snowflake_local_db.library.register_table_or_view(
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS'],
    false,
    false,
    false,
    false);
Copy

要注册 Iceberg 表:

call samooha_by_snowflake_local_db.library.register_table_or_view(
        ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS'], 
        false, 
        true,
        false,
        false);
Copy

library.register_table – 已弃用

注意

此命令现已弃用。 改用 library.register_objects

描述:register_db 类似,但在表级运行。将此表的 SELECT 权限授予 SAMOOHA_APP_ROLE 角色,使用户能够将表链接到 Clean Room。

如果要在托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构)中注册表,请改用 library.register_managed_access_table

实参: table_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_table(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.register_managed_access_table – 已弃用

注意

此命令现已弃用。 改用 library.register_objects

描述:类似于 register_table,但在使用 WITH MANAGED ACCESS 参数创建的架构中注册表。可以传入表示完全限定表名称的数组或字符串,并授予 SAMOOHA_APP_ROLE 角色选择权限,使用户能够将表链接到 clean room 中。

实参: table_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_managed_access_table(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.register_view – 已弃用

注意

此命令现已弃用。 改用 library.register_objects

描述:register_db 类似,但在视图级运行。可以传入表示完全限定视图名称的数组或字符串,并授予 SAMOOHA_APP_ROLE 角色选择权限,使用户能够将视图链接到 clean room 中。

如果要在托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构)中注册视图,请改用 library.register_managed_access_view

实参: view_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_view(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.register_managed_access_view – 已弃用

注意

此命令现已弃用。 改用 library.register_objects

描述: 类似于 register_view,但在使用 WITH MANAGED ACCESS 参数创建的架构中注册视图。可以传入表示完全限定视图名称的数组或字符串,并授予 SAMOOHA_APP_ROLE 角色选择权限,使用户能够将视图链接到 clean room 中。

实参: view_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.register_managed_access_view(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.unregister_table_or_view – 已弃用

注意

此命令现已弃用。 改用 library.unregister_objects

描述: 取消注册所有类型的表和视图。

实参: object_names(数组)、is_view(布尔)、is_iceberg(布尔)、is_external(布尔)、is_under_managed_access_schema(布尔)

返回: (字符串) 成功或失败消息。

示例

要取消注册表:

call samooha_by_snowflake_local_db.library.unregister_table_or_view(
    ['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS'],
    false,
    false,
    false,
    false);
Copy

library.unregister_table – 已弃用

注意

此命令现已弃用。 改用 library.unregister_objects

描述:unregister_db 类似,但在表级运行。可以传入表示完全限定表名称的数组或字符串来取消注册表。用户无法将取消注册的表链接到 Clean Room 中。

如果要在托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构)中取消注册表,请改用 library.unregister_managed_access_table

实参: table_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_table(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.unregister_managed_access_table – 已弃用

注意

此命令现已弃用。 改用 library.unregister_objects

描述:类似于 unregister_table,但在托管访问架构(即使用 WITH MANAGED ACCESS 创建的架构)中取消注册表。

实参: table_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_managed_access_table(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.unregister_view – 已弃用

注意

此命令现已弃用。 改用 library.unregister_objects

描述:unregister_db 类似,但在视图级运行。可以传入表示完全限定视图名称的数组或字符串来取消注册视图。用户无法将取消注册的视图链接到 Clean Room 中。

如果要在托管访问架构(即使用 WITH MANAGED ACCESS 参数创建的架构)中注册视图,请改用 library.unregister_managed_access_view

实参: view_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_view(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

library.unregister_managed_access_view – 已弃用

注意

此命令现已弃用。 改用 library.unregister_objects

描述:类似于 unregister_view,但在托管访问架构(即使用 WITH MANAGED ACCESS 创建的架构)中取消注册视图。

实参: view_name(数组)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.library.unregister_managed_access_view(['SAMOOHA_SAMPLE_DATABASE.DEMO.CUSTOMERS']);
Copy

provider.create_cleanroom_listing – 已弃用

注意

此命令现已弃用。 改用 provider.create_or_update_cleanroom_listing

描述: 配置 Clean Room 后,在 Snowflake Marketplace 上创建该 Clean Room 的专用列表,并与指定的协作者共享。

您可以使用账户 URL 的 orgname.account_name 格式来识别协作者。使用者可以按照 查找账户的组织和账户名称 (https://user-guide/admin-account-identifier#finding-the-organization-and-account-name-for-an-account) 中的说明查找此字符串。

备注

要使用此程序,您需要设置发布指令。有关更多信息,请参阅 provider.set_default_release_directive

实参: cleanroom_name(字符串)、consumer_account_name(字符串)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.create_cleanroom_listing($cleanroom_name, <consumerorg.consumeracct>);
Copy

provider.register_cleanroom_in_ui -- DEPRECATED

注意

此命令现已弃用。 您不再需要手动注册 Clean Room 模板以在 Web 应用程序中使用。

描述: 注册 Clean Room,供使用者在 Web 应用程序中使用。Clean Room 由提供商使用开发者 APIs 创建和配置。然后,该命令会将其注册到 Web 应用程序中,供使用者安装、添加表并运行您添加的任何自定义分析,而无需使用开发者 APIs。他们完全通过 Web 应用程序的用户界面使用 Clean Room。

您可以多次调用该 API,将多个自定义模板添加到 Web 应用程序中。

实参: cleanroom_name(字符串)、template name(字符串)、consumer_account_locator(字符串)、user_email(字符串)

返回: (字符串) 成功或失败消息。

示例:

call samooha_by_snowflake_local_db.provider.register_cleanroom_in_ui($cleanroom_name, 'prod_custom_template', <CONSUMER ACCOUNT LOCATOR>, <USER_EMAIL>)
Copy
语言: 中文