コスト帰属¶

タグの作成¶

戦略設計の一環として、タグを作成する予定のデータベースとスキーマを決定します。

• タグ専用のデータベースとスキーマを作成することができます。

• 組織内の異なるアカウントにあるリソースにタグを付けたい場合は、組織内のキーアカウント（組織アカウント など）にタグを作成します。

次の例では、 cost_management という名前のデータベースと tags という名前のスキーマを使用する予定のタグ用に作成します。

USE ROLE tag_admin;

CREATE DATABASE cost_management;
CREATE SCHEMA tags;

現在のデータベースとスキーマとして cost_management と tags を選択した状態で、 cost_center というタグを作成し、そのタグに許容される値をコストセンターの名前にセットします。

CREATE TAG cost_center
  ALLOWED_VALUES 'finance', 'marketing', 'engineering', 'product';

タグデータベースの複製¶

複数のアカウントを持つ組織があり、これらの他のアカウントでタグを使用できるようにしたい場合、 複製用にアカウントをセットアップ し、メインアカウントで 複製グループを作成 します（組織アカウント など）。タグを含むデータベースを複製するために、この複製グループをセットアップします。

たとえば、 my_org.my_account と my_org.my_account_2 というアカウントにタグを複製するには、組織アカウントで次のステートメントを実行します。

CREATE REPLICATION GROUP cost_management_repl_group
  OBJECT_TYPES = DATABASES
  ALLOWED_DATABASES = cost_management
  ALLOWED_ACCOUNTS = my_org.my_account_1, my_org.my_account_2
  REPLICATION_SCHEDULE = '10 MINUTE';

次に、タグを使用可能にしたい各アカウントで、セカンダリの複製グループを作成し、プライマリグループからこのグループを更新します。

CREATE REPLICATION GROUP cost_management_repl_group
  AS REPLICA OF my_org.my_org_account.cost_management_repl_group;

ALTER REPLICATION GROUP cost_management_repl_group REFRESH;

リソースとユーザーのタグ付け¶

タグを作成し複製したら、これらのタグを使用して、各部門に属するウェアハウスとユーザーを識別できます。例えば、販売部門は warehouse1 と warehouse2 の両方を使用しているため、 cost_center タグを両方のウェアハウスの 'SALES' に設定します。

USE ROLE tag_admin;

ALTER WAREHOUSE warehouse1 SET TAG cost_management.tags.cost_center='SALES';
ALTER WAREHOUSE warehouse2 SET TAG cost_management.tags.cost_center='SALES';
ALTER WAREHOUSE warehouse3 SET TAG cost_management.tags.cost_center='FINANCE';

ALTER USER finance_user SET TAG cost_management.tags.cost_center='FINANCE';
ALTER USER sales_user SET TAG cost_management.tags.cost_center='SALES';

Automating user tags with SCIM¶

If you want to automate the process of tagging users for cost attribution, you can do so by provisioning Snowflake users through a SCIM identity provider such as Microsoft Entra ID or Okta. With SCIM, you can automatically apply cost attribution tags to users when they're created or updated, eliminating the need to run ALTER USER <user_name> SET TAG manually for each new user and keeping your cost attribution tags consistent as users join or move between departments.

When using SCIM, the snowflakeTags custom attribute accepts a comma-separated list of fully qualified tag references. For example, to assign a user to the finance cost center at provisioning time, include the following value in the SCIM user payload:

{
  "userName": "JSMITH",
  "displayName": "Jane Smith",
  "urn:ietf:params:scim:schemas:extension:enterprise:2.0:User": {
    "snowflakeUserName": "JSMITH",
    "snowflakeTags": "[cost_management.tags.cost_center:finance]"
  }
}

Tags set through SCIM appear in the same TAG_REFERENCES views and work with Snowsight tag filters (see Snowsight でのタグ別のコスト表示), so your existing cost attribution queries and dashboards work without changes.

To get started with this approach, you need to:

• Create the tags in Snowflake, as described in Creating the tags above.

• Grant the SCIM provisioner role USAGE on the tag schema and APPLY on each tag.

For the complete setup steps, prerequisite grants, and API examples, see the "Populating Snowflake tags with SCIM integrations" section in:

• SCIM with Microsoft Entra ID

• SCIM with Okta

• SCIM with a custom identity provider

部門間で共有されていないリソース¶

部門別にコスト帰属を設定し、各部門が専用ウェアハウスのセットを使用しているとします。

ウェアハウスを所有する部門を特定する cost_center タグでウェアハウスにタグ付けする場合、 object_id と warehouse_id 列で ACCOUNT_USAGE TAG_REFERENCES ビュー と WAREHOUSE_METERING_HISTORY ビュー を結合して、ウェアハウス別の使用情報を取得します。また、 tag_value 列を使用すると、それらのウェアハウスを所有する部門を特定できます。

次のSQLステートメントは、この結合を実行します。

SELECT
    TAG_REFERENCES.tag_name,
    COALESCE(TAG_REFERENCES.tag_value, 'untagged') AS tag_value,
    SUM(WAREHOUSE_METERING_HISTORY.credits_used_compute) AS total_credits
  FROM
    SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
      LEFT JOIN SNOWFLAKE.ACCOUNT_USAGE.TAG_REFERENCES
        ON WAREHOUSE_METERING_HISTORY.warehouse_id = TAG_REFERENCES.object_id
          AND TAG_REFERENCES.domain = 'WAREHOUSE'
  WHERE
    WAREHOUSE_METERING_HISTORY.start_time >= DATE_TRUNC('MONTH', DATEADD(MONTH, -1, CURRENT_DATE))
      AND WAREHOUSE_METERING_HISTORY.start_time < DATE_TRUNC('MONTH',  CURRENT_DATE)
  GROUP BY TAG_REFERENCES.tag_name, COALESCE(TAG_REFERENCES.tag_value, 'untagged')
  ORDER BY total_credits DESC;

+-------------+-------------+-----------------+
| TAG_NAME    | TAG_VALUE   |   TOTAL_CREDITS |
|-------------+-------------+-----------------|
| NULL        | untagged    |    20.360277159 |
| COST_CENTER | Sales       |    17.173333333 |
| COST_CENTER | Finance     |      8.14444444 |
+-------------+-------------+-----------------+

組織アカウント のORGANIZATION_USAGEスキーマのビューを使用して、組織内のすべてのアカウントに対して同じ 属性を実行する場合は同様のクエリを実行できます。残りのクエリは変わりません。

SELECT
    TAG_REFERENCES.tag_name,
    COALESCE(TAG_REFERENCES.tag_value, 'untagged') AS tag_value,
    SUM(WAREHOUSE_METERING_HISTORY.credits_used_compute) AS total_credits
  FROM
    SNOWFLAKE.ORGANIZATION_USAGE.WAREHOUSE_METERING_HISTORY
      LEFT JOIN SNOWFLAKE.ORGANIZATION_USAGE.TAG_REFERENCES
        ON WAREHOUSE_METERING_HISTORY.warehouse_id = TAG_REFERENCES.object_id
          AND TAG_REFERENCES.domain = 'WAREHOUSE'
          AND tag_database = 'COST_MANAGEMENT' AND tag_schema = 'TAGS'
  WHERE
    WAREHOUSE_METERING_HISTORY.start_time >= DATE_TRUNC('MONTH', DATEADD(MONTH, -1, CURRENT_DATE))
      AND WAREHOUSE_METERING_HISTORY.start_time < DATE_TRUNC('MONTH',  CURRENT_DATE)
  GROUP BY TAG_REFERENCES.tag_name, COALESCE(TAG_REFERENCES.tag_value, 'untagged')
  ORDER BY total_credits DESC;

異なる部門のユーザーが共有するリソース¶

異なる部門のユーザーが同じウェアハウスを共有しており、各部門が使用するクレジットを分類したいとします。ユーザーの所属部署を識別するために、 cost_center タグを付けて、 TAG_REFERENCES ビュー と QUERY_ATTRIBUTION_HISTORY ビュー を結合します。

次のセクションでは、共有リソースのコスト帰属を設定するSQLステートメントの例を示します。

• 先月のユーザークエリのコストの計算

• 部門別のユーザークエリのコストの計算（アイドルタイムなし）

• ユーザー別のクエリのコストの計算（アイドルタイムなし）

• タグを持たないユーザー別のクエリのコストの計算

WITH
  wh_bill AS (
    SELECT SUM(credits_used_compute) AS compute_credits
      FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
      WHERE start_time >= DATE_TRUNC('MONTH', CURRENT_DATE)
        AND start_time < CURRENT_DATE
  ),
  user_credits AS (
    SELECT user_name, SUM(credits_attributed_compute) AS credits
      FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
      WHERE start_time >= DATE_TRUNC('MONTH', CURRENT_DATE)
        AND start_time < CURRENT_DATE
      GROUP BY user_name
  ),
  total_credit AS (
    SELECT SUM(credits) AS sum_all_credits
    FROM user_credits
  )
SELECT
    u.user_name,
    u.credits / t.sum_all_credits * w.compute_credits AS attributed_credits
  FROM user_credits u, total_credit t, wh_bill w
  ORDER BY attributed_credits DESC;

+-----------+--------------------+
| USER_NAME | ATTRIBUTED_CREDITS |
|-----------+--------------------+
| FINUSER   | 6.603575468        |
| SALESUSER | 4.321378049        |
| ENGUSER   | 0.6217131392       |
|-----------+--------------------+

WITH joined_data AS (
  SELECT
      tr.tag_name,
      tr.tag_value,
      qah.credits_attributed_compute,
      qah.start_time
    FROM SNOWFLAKE.ACCOUNT_USAGE.TAG_REFERENCES tr
      JOIN SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY qah
        ON tr.domain = 'USER' AND tr.object_name = qah.user_name
)
SELECT
    tag_name,
    tag_value,
    SUM(credits_attributed_compute) AS total_credits
  FROM joined_data
  WHERE start_time >= DATEADD(MONTH, -1, CURRENT_DATE)
    AND start_time < CURRENT_DATE
  GROUP BY tag_name, tag_value
  ORDER BY tag_name, tag_value;

+-------------+-------------+-----------------+
| TAG_NAME    | TAG_VALUE   |   TOTAL_CREDITS |
|-------------+-------------+-----------------|
| COST_CENTER | engineering |   0.02493688426 |
| COST_CENTER | finance     |    0.2281084988 |
| COST_CENTER | marketing   |    0.3686840545 |
|-------------+-------------+-----------------|

SELECT user_name, SUM(credits_attributed_compute) AS credits
  FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
  WHERE
    start_time >= DATEADD(MONTH, -1, CURRENT_DATE)
    AND start_time < CURRENT_DATE
  GROUP BY user_name;

+-----------+--------------------+
| USER_NAME | ATTRIBUTED_CREDITS |
|-----------+--------------------|
| JSMITH    |       17.173333333 |
| MJONES    |         8.14444444 |
| SYSTEM    |         5.33985393 |
+-----------+--------------------+

SELECT qah.user_name, SUM(qah.credits_attributed_compute) as total_credits
  FROM
    SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY qah
    LEFT JOIN snowflake.account_usage.tag_references tr
    ON qah.user_name = tr.object_name AND tr.DOMAIN = 'USER'
  WHERE
    start_time >= dateadd(month, -1, current_date)
    AND qah.user_name IS NULL OR tr.object_name IS NULL
  GROUP BY qah.user_name
  ORDER BY total_credits DESC;

+------------+---------------+
| USER_NAME  | TOTAL_CREDITS |
|------------+---------------|
| RSMITH     |  0.1830555556 |
+------------+---------------+

異なる部門にコスト帰属を設定する必要があるアプリケーションで使用されるリソース¶

このセクションの例では、Snowflakeを使用する1つまたは複数のアプリケーションのコストを計算しています。

この例では、これらのアプリケーションが、実行されるすべてのクエリに対してアプリケーションを識別するクエリタグをセットすることを想定しています。セッション内のクエリにクエリタグをセットするには、 ALTER SESSION コマンドを実行します。例:

ALTER SESSION SET QUERY_TAG = 'COST_CENTER=finance';

これにより、 COST_CENTER=finance タグがセッション中に実行される後続のすべてのクエリに関連付けられます。

そして、クエリタグを使用して、これらのクエリで発生したコストを適切な部門にトレースバックすることができます。

次のセクションでは、このアプローチの使用例を示します。

• 部門別のクエリのコストの計算

• クエリタグ別のクエリのコストの計算（アイドル時間を除く）

• クエリタグ別のクエリのコストの計算（アイドル時間を含む）

SELECT
    query_tag,
    SUM(credits_attributed_compute) AS compute_credits,
    SUM(credits_used_query_acceleration) AS qas
  FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
  WHERE query_tag = 'COST_CENTER=finance'
  GROUP BY query_tag;

+---------------------+-----------------+------+
| QUERY_TAG           | COMPUTE_CREDITS | QAS  |
|---------------------+-----------------|------|
| COST_CENTER=finance |      0.00576115 | null |
+---------------------+-----------------+------+

SELECT
    COALESCE(NULLIF(query_tag, ''), 'untagged') AS tag,
    SUM(credits_attributed_compute) AS compute_credits,
    SUM(credits_used_query_acceleration) AS qas
  FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
  WHERE start_time >= DATEADD(MONTH, -1, CURRENT_DATE)
  GROUP BY tag
  ORDER BY compute_credits DESC;

+-------------------------+-----------------+------+
| TAG                     | COMPUTE_CREDITS | QAS  |
|-------------------------+-----------------+------+
| untagged                | 3.623173449     | null |
| COST_CENTER=engineering | 0.531431948     | null |
|-------------------------+-----------------+------+

WITH
  wh_bill AS (
    SELECT SUM(credits_used_compute) AS compute_credits
      FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
      WHERE start_time >= DATE_TRUNC('MONTH', CURRENT_DATE)
      AND start_time < CURRENT_DATE
  ),
  tag_credits AS (
    SELECT
        COALESCE(NULLIF(query_tag, ''), 'untagged') AS tag,
        SUM(credits_attributed_compute) AS credits
      FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
      WHERE start_time >= DATEADD(MONTH, -1, CURRENT_DATE)
      GROUP BY tag
  ),
  total_credit AS (
    SELECT SUM(credits) AS sum_all_credits
      FROM tag_credits
  )
SELECT
    tc.tag,
    tc.credits / t.sum_all_credits * w.compute_credits AS attributed_credits
  FROM tag_credits tc, total_credit t, wh_bill w
  ORDER BY attributed_credits DESC;

+-------------------------+--------------------+
| TAG                     | ATTRIBUTED_CREDITS |
+-------------------------+--------------------|
| untagged                |        9.020031304 |
| COST_CENTER=finance     |        1.027742521 |
| COST_CENTER=engineering |        1.018755812 |
| COST_CENTER=marketing   |       0.4801370376 |
+-------------------------+--------------------+

類似クエリのグループ化¶

反復または類似のクエリの場合は、 query_hash または query_parameterized_hash を使用して、クエリごとにコストをグループ化します。

当月で最も高額な反復クエリを検索するには、以下のステートメントを実行します:

SELECT query_parameterized_hash,
       COUNT(*) AS query_count,
       SUM(credits_attributed_compute) AS total_credits
  FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
  WHERE start_time >= DATE_TRUNC('MONTH', CURRENT_DATE)
  AND start_time < CURRENT_DATE
  GROUP BY query_parameterized_hash
  ORDER BY total_credits DESC
  LIMIT 20;

クエリ ID に基づく追加クエリについては、 例 を参照してください。

階層クエリのコスト帰属の設定¶

複数の階層クエリを発行するストアドプロシージャの場合、プロシージャのルートクエリ ID を使用して、プロシージャの帰属クエリコストを計算できます。

1. ストアドプロシージャのルートクエリ ID を見つけるには、 ACCESS_HISTORY ビュー を使用します。例えば、ストアドプロシージャのルートクエリ ID を見つけるには、 query_id を設定し、以下のステートメントを実行します:

   CopyExpand

   SET query_id = '<query_id>';
   
   SELECT query_id,
          parent_query_id,
          root_query_id,
          direct_objects_accessed
     FROM SNOWFLAKE.ACCOUNT_USAGE.ACCESS_HISTORY
     WHERE query_id = $query_id;
   

   Show lessSee more

   Scroll to top

   詳細については、 ストアドプロシージャによる祖先クエリ をご参照ください。

2. プロシージャ全体のクエリコストを合計するには、 < root_query_id > を置き換え、以下のステートメントを実行します:

   CopyExpand

   SET query_id = '<root_query_id>';
   
   SELECT SUM(credits_attributed_compute) AS total_attributed_credits
     FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_ATTRIBUTION_HISTORY
     WHERE (root_query_id = $query_id OR query_id = $query_id);
   

   Show lessSee more

   Scroll to top