Utilisation du service Query Acceleration¶

Requêtes inéligibles¶

Certaines requêtes ne sont pas éligibles pour l’accélération des requêtes. Voici les raisons courantes pour lesquelles une requête ne peut pas être accélérée :

• Il n’y a pas de filtres ni d’agrégation (c’est-à-dire GROUP BY). Query Acceleration Service est actuellement incapable d’accélérer de telles requêtes.

• Les filtres ne sont pas assez sélectifs. Par ailleurs, l’expression GROUP BY a une cardinalité élevée.

• Il n’y a pas assez de partitions. L’avantage de l’accélération des requêtes serait compensé par la latence de l’acquisition de serveurs supplémentaires pour le service s’il n’y a pas assez de partitions à analyser.

• Le service Query Acceleration n’accélère pas les requêtes sur les tables pour lesquelles l’optimisation des recherches est activée.

• La requête comprend une clause LIMIT. Cependant, une clause LIMIT avec une clause ORDER BY est prise en charge.

Identifier les requêtes avec la fonction SYSTEM$ESTIMATE_QUERY_ACCELERATION¶

La fonction SYSTEM$ESTIMATE_QUERY_ACCELERATION peut aider à déterminer si une requête exécutée précédemment peut bénéficier du service d’accélération des requêtes. Si la requête est éligible à l’accélération des requêtes, la fonction renvoie le temps d’exécution estimé de la requête pour différents facteurs d’échelle d’accélération.

select parse_json(system$estimate_query_acceleration('8cd54bf0-1651-5b1c-ac9c-6a9582ebd20f'));

{
  "estimatedQueryTimes": {
    "1": 171,
    "10": 115,
    "2": 152,
    "4": 133,
    "8": 120
  },
  "originalQueryTime": 300.291,
  "queryUUID": "8cd54bf0-1651-5b1c-ac9c-6a9582ebd20f",
  "status": "eligible",
  "upperLimitScaleFactor": 10
}

select parse_json(system$estimate_query_acceleration('cf23522b-3b91-cf14-9fe0-988a292a4bfa'));

{
  "estimatedQueryTimes": {},
  "originalQueryTime": 20.291,
  "queryUUID": "cf23522b-3b91-cf14-9fe0-988a292a4bfa",
  "status": "ineligible",
  "upperLimitScaleFactor": 0
}

Identifier les requêtes et les entrepôts avec la vue QUERY_ACCELERATION_ELIGIBLE¶

Interrogez Vue QUERY_ACCELERATION_ELIGIBLE pour identifier les requêtes et les entrepôts qui pourraient bénéficier le plus du service d’accélération des requêtes. Pour chaque requête, la vue inclut la quantité de temps d’exécution de la requête qui est éligible pour le service d’accélération des requêtes.

USE ROLE ACCOUNTADMIN;

USE SCHEMA snowflake.account_usage;

SELECT query_id, eligible_query_acceleration_time
FROM QUERY_ACCELERATION_ELIGIBLE
ORDER BY eligible_query_acceleration_time DESC;

SELECT query_id, eligible_query_acceleration_time
FROM QUERY_ACCELERATION_ELIGIBLE
WHERE warehouse_name = 'mywh'
ORDER BY eligible_query_acceleration_time DESC;

SELECT warehouse_name, COUNT(query_id) AS num_eligible_queries
FROM query_acceleration_eligible
WHERE start_time > 'Tue, 18 January 2022 12:00:00'::timestamp
AND end_time < 'Tue, 19 January 2022 00:00:00'::timestamp
GROUP BY warehouse_name
ORDER BY num_eligible_queries DESC;

SELECT warehouse_name, SUM(eligible_query_acceleration_time) AS total_eligible_time
FROM QUERY_ACCELERATION_ELIGIBLE
GROUP BY warehouse_name
ORDER BY total_eligible_time DESC;

SELECT MAX(upper_limit_scale_factor)
FROM QUERY_ACCELERATION_ELIGIBLE
WHERE warehouse_name = 'mywh';

Commandes SQL prises en charge¶

Le service d’accélération des requêtes prend en charge les commandes suivantes SQL :

• SELECT

• INSERT (lorsque l’instruction contient une instruction SELECT)

• CREATE TABLE AS SELECT (CTAS)

Une requête, ou une partie d’une requête (c’est-à-dire une sous-requête ou une clause), avec une commande SQL prise en charge peuvent être accélérées par Query Acceleration Service si elles sont éligibles à l’accélération.

Exemples¶

L’exemple suivant active Query Acceleration Service pour un entrepôt nommé my_wh :

create warehouse my_wh with
  ENABLE_QUERY_ACCELERATION = true;

Exécutez la commande SHOW WAREHOUSES pour afficher les détails de l’entrepôt my_wh.

show warehouses like 'my_wh';

+---------+---------+----------+---------+---------+--------+------------+------------+--------------+-------------+-----------+--------------+-----------+-------+-------------------------------+-------------------------------+-------------------------------+--------------+---------+---------------------------+-------------------------------------+------------------+---------+----------+--------+-----------+------------+
| name    | state   | type     | size    | running | queued | is_default | is_current | auto_suspend | auto_resume | available | provisioning | quiescing | other | created_on                    | resumed_on                    | updated_on                    | owner        | comment | enable_query_acceleration | query_acceleration_max_scale_factor | resource_monitor | actives | pendings | failed | suspended | uuid       |
|---------+---------+----------+---------+---------+--------+------------+------------+--------------+-------------+-----------+--------------+-----------+-------+-------------------------------+-------------------------------+-------------------------------+--------------+---------+---------------------------+-------------------------------------+------------------+---------+----------+--------+-----------+------------|
| MY_WH   | SUSPENDED | STANDARD | Medium |       0 |      0 | N          | N          |          600 | true        |           |              |           |       | 2023-01-20 14:31:49.283 -0800 | 2023-01-20 14:31:49.388 -0800 | 2023-01-20 16:34:28.583 -0800 | ACCOUNTADMIN |         | true                      |                                   8 | null             |       0 |        0 |      0 |         4 | 1132659053 |
+---------+---------+----------+---------+---------+--------+------------+------------+--------------+-------------+-----------+--------------+-----------+-------+-------------------------------+-------------------------------+-------------------------------+--------------+---------+---------------------------+-------------------------------------+------------------+---------+----------+--------+-----------+------------+

Le service d’accélération des requêtes peut augmenter le taux de consommation des crédits d’un entrepôt. Le facteur d’échelle maximal peut contribuer à limiter le taux de consommation. Voir CREATE WAREHOUSE ou ALTER WAREHOUSE pour plus de détails sur la propriété QUERY_ACCELERATION_MAX_SCALE_FACTOR.

La vue QUERY_ACCELERATION_ELIGIBLE et la fonction SYSTEM$ESTIMATE_QUERY_ACCELERATION peuvent être utiles pour déterminer un facteur d’échelle approprié pour un entrepôt. Pour plus de détails, voir Identification des requêtes et des entrepôts qui pourraient bénéficier de Query Acceleration (dans ce chapitre).

Exemple¶

L’exemple suivant modifie l’entrepôt nommé my_wh pour activer Query Acceleration Service avec un facteur d’échelle maximum de 0.

alter warehouse my_wh set
  ENABLE_QUERY_ACCELERATION = true
  QUERY_ACCELERATION_MAX_SCALE_FACTOR = 0;

Utilisation de l’interface Web pour surveiller l’utilisation de Query Acceleration¶

Une fois que vous avez activé le service d’accélération des requêtes, vous pouvez consulter le panneau Présentation du profil dans Profil des requêtes pour voir les effets des résultats de l’accélération des requêtes.

La capture d’écran suivante montre un exemple des statistiques affichées pour la requête globale. Si plusieurs opérations d’une requête ont été accélérées, les résultats sont agrégés dans cette vue afin que vous puissiez voir la quantité totale de travail effectué par le service d’accélération des requêtes.

La section Query Acceleration du panneau Profile Overview comprend les statistiques suivantes :

• Partitions analysées par le service — nombre de fichiers déchargés dont l’analyse a été confiée au service d’accélération des requêtes.

• Analyses sélectionnées pour l’accélération — nombre d’analyses de table en cours d’accélération.

Dans les détails de l’opérateur (voir Vue d’ensemble du profil/détails sur l’opérateur pour plus d’informations), cliquez sur l’opérateur pour voir des informations détaillées. La capture d’écran suivante montre un exemple des statistiques affichées pour une opération TableScan :

La section Query Acceleration du panneau de détails TableScan comprend les statistiques suivantes :

• Partitions analysées par le service — nombre de fichiers déchargés dont l’analyse a été confiée au service d’accélération des requêtes.

Utilisation de la vue QUERY_HISTORY Account Usage pour surveiller l’utilisation de Query Acceleration¶

Pour voir les effets de l’accélération des requêtes sur une requête, vous pouvez utiliser les colonnes suivantes dans Vue QUERY_HISTORY.

• QUERY_ACCELERATION_BYTES_SCANNED

• QUERY_ACCELERATION_PARTITIONS_SCANNED

• QUERY_ACCELERATION_UPPER_LIMIT_SCALE_FACTOR

Vous pouvez utiliser ces colonnes pour identifier les requêtes qui ont bénéficié du service d’accélération des requêtes. Pour chaque requête, vous pouvez également déterminer le nombre total de partitions et d’octets analysés par le service d’accélération des requêtes.

Pour la description de chacune de ces colonnes, voir Vue QUERY_HISTORY.

Par exemple, pour trouver les requêtes ayant le plus d’octets analysés par le service d’accélération des requêtes au cours des 24 dernières heures :

SELECT * FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY
WHERE QUERY_ACCELERATION_PARTITIONS_SCANNED > 0
AND start_time >= DATEADD(hour, -24, CURRENT_TIMESTAMP())
ORDER BY QUERY_ACCELERATION_BYTES_SCANNED DESC;

Trouver les requêtes avec le plus grand nombre de partitions analysées par le service d’accélération des requêtes dans les 24 dernières heures :

SELECT * FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY
WHERE QUERY_ACCELERATION_PARTITIONS_SCANNED > 0
AND start_time >= DATEADD(hour, -24, CURRENT_TIMESTAMP())
ORDER BY QUERY_ACCELERATION_PARTITIONS_SCANNED DESC;

Affichage des informations de facturation dans l’interface Web classique¶

Si Query Acceleration est activé pour votre compte, la page de facturation de l’interface Web comprend un entrepôt appelé QUERY_ACCELERATION qui indique tous les crédits utilisés par le service dans tous les entrepôts de votre compte.

La capture d’écran ci-dessous montre un exemple des informations de facturation affichées pour l’entrepôt QUERY_ACCELERATION :

Visualisation de la facturation en utilisant la vue QUERY_ACCELERATION_HISTORY Account Usage¶

Vous pouvez voir les données de facturation dans Vue QUERY_ACCELERATION_HISTORY Account Usage.

select warehouse_name,
       sum(credits_used) as total_credits_used
from snowflake.account_usage.query_acceleration_history
where start_time >= date_trunc(month, current_date)
group by 1
order by 2 desc;

Affichage de la facturation à l’aide de la fonction QUERY_ACCELERATION_HISTORY¶

Vous pouvez également consulter les données de facturation à l’aide de la fonction Information Schema QUERY_ACCELERATION_HISTORY.