Utilisation d’entrepôts¶

Création d’un entrepôt¶

Vous pouvez créer un entrepôt en utilisant les interfaces suivantes :

Snowsight:

Sélectionnez Admin » Warehouses » Warehouse

Classic Console:

Sélectionnez Warehouses » Create

SQL:

Exécutez une commande CREATE WAREHOUSE.

Python:

Utilisez WarehouseCollection.create API (Création d’un entrepôt).

Lorsque vous créez un entrepôt, vous pouvez spécifier si l’entrepôt est créé initialement à l’état « Démarré » (c’est-à-dire en cours exécution) ou « Suspendu ». Si vous choisissez « Démarré », l’entrepôt commence à consommer des crédits dès que toutes les ressources de calcul sont mises en service pour l’entrepôt.

Démarrage ou reprise d’un entrepôt¶

Un entrepôt peut être démarré à tout moment, y compris lors de la création initiale. Une fois qu’un entrepôt est créé, la reprise d’un magasin est la même chose que le démarrage d’un magasin.

Vous pouvez reprendre un entrepôt suspendu (c’est-à-dire inactif) en utilisant les interfaces suivantes :

Snowsight:

Sélectionnez Admin » Warehouses » <nom_entrepôt_suspendu> » » Resume

Classic Console:

Sélectionnez Warehouses » <nom_entrepôt_suspendu> » Resume

SQL:

Exécutez une commande ALTER WAREHOUSE avec le mot-clé RESUME.

Python:

Utilisez WarehouseResource.resume API (Réalisation d’opérations d’entrepôt).

Le démarrage d’un entrepôt ne prend généralement que quelques secondes. Cependant, dans de rares cas, cela peut prendre plus de temps car Snowflake met en service les ressources de calcul qui fournissent les ressources de calcul de l’entrepôt.

Les entrepôts consomment des crédits en cours d’exécution :

• Un entrepôt commence à consommer des crédits une fois que toutes les ressources de calcul sont provisionnées pour l’entrepôt.

  • Dans de rares cas, lorsque certaines des ressources de calcul ne parviennent pas à être provisionnées, l’entrepôt consomme uniquement des crédits pour les ressources de calcul provisionnées.

  • Une fois que les ressources de calcul restantes ont été provisionnées, l’entrepôt commence à consommer des crédits pour toutes les ressources de calcul demandées.

• Bien que le démarrage ou la reprise d’un entrepôt ne prenne souvent que quelques secondes, dans certains cas, cela peut prendre plus de temps, car Snowflake met en service les ressources de calcul qui fournissent les ressources de calcul de l’entrepôt.

• Snowflake n’exécute pas les instructions SQL soumises à un entrepôt tant que toutes les ressources de calcul de l’entrepôt n’ont pas été mises en service avec succès, à moins que l’une des ressources ne puisse pas être mise en service :

  • Si l’une des ressources de calcul de l’entrepôt n’arrive pas à être mise en service durant le démarrage, Snowflake tente de réparer les ressources échouées.

  • Pendant le processus de réparation, l’entrepôt commence à traiter les instructions SQL une fois que 50% ou plus des ressources de calcul demandées ont été mises en service avec succès.

Les crédits sont facturés à la seconde pendant le fonctionnement de l’entrepôt, avec un minimum d’une minute chaque fois que l’entrepôt reprend. Toutefois, la consommation de crédit est indiquée par tranches de 60 minutes (c.-à-d. par heure).

Suspension d’un entrepôt¶

Un entrepôt en cours d’exécution peut être suspendu à tout moment, même pendant l’exécution d’instructions SQL. En suspendant un entrepôt, cet entrepôt arrête de consommer des crédits une fois toutes les ressources de calcul arrêtées.

Vous pouvez suspendre un entrepôt en utilisant les interfaces suivantes :

Snowsight:

Sélectionnez Admin » Warehouses » <nom_entrepôt_démarré> » » Suspend

Classic Console:

Sélectionnez Warehouses » <nom_entrepôt_démarré> » Suspend

SQL:

Exécutez une commande ALTER WAREHOUSE avec le mot-clé SUSPEND.

Python:

Utilisez WarehouseResource.suspend API (Réalisation d’opérations d’entrepôt).

Lorsque vous suspendez un entrepôt, Snowflake ferme immédiatement toutes les ressources de calcul inactives de l’entrepôt, mais permet à toutes les ressources de calcul qui exécutent des instructions de continuer jusqu’à ce que les instructions aient abouti, moment auquel les ressources sont éteintes et le statut de l’entrepôt passe à « Suspendu ». Les ressources de calcul en attente d’arrêt sont considérées comme étant en mode « repos ».

Redimensionnement d’un entrepôt¶

Les dimensions d’un entrepôt peuvent être augmentées ou diminuées à tout moment, y compris pendant l’exécution et le traitement d’instructions.

Vous pouvez redimensionner un entrepôt en utilisant les interfaces suivantes :

Snowsight:

Sélectionnez Admin » Warehouses » <nom_entrepôt> » » Edit

Classic Console:

Sélectionnez Warehouses » <nom_entrepôt> » Configure

SQL:

Exécutez une commande ALTER WAREHOUSE avec SET WAREHOUSE_SIZE = ....

Python:

Utilisez WarehouseResource.create_or_alter API (Création ou modification d’un entrepôt).

Le redimensionnement d’un entrepôt vers une taille plus grande est utile si les opérations effectuées par l’entrepôt pourront bénéficier de ressources de calcul supplémentaires et :

• Améliorer les performances des grandes requêtes complexes par rapport à de grands jeux de données.

• Améliorer les performances lors du chargement et du déchargement de grandes quantités de données.

Utilisation d’un entrepôt¶

Pour exécuter une requête ou une instruction DML dans Snowflake, un entrepôt doit être en cours d’exécution et il doit être spécifié comme l’entrepôt actuel pour la session dans laquelle la requête/l’instruction est soumise.

Une session Snowflake ne peut avoir qu’un seul entrepôt actuel à la fois. L’entrepôt actuel de la session peut être spécifié ou modifié à tout moment au moyen de la commande SQL USE WAREHOUSE ou de la commande WarehouseResource.use_warehouse Python API.

Une fois qu’un entrepôt en cours d’exécution a été défini comme étant l’entrepôt actuel pour la session, les requêtes et instructions DML soumises au cours de la session sont traitées par l’entrepôt. Dans les pages History et Worksheets de l”Classic Console, vous pouvez voir l’entrepôt utilisé pour traiter chaque requête/instruction.

Délégation de la gestion des entrepôts¶

Par défaut, le rôle ACCOUNTADMIN permet de modifier, de suspendre, de décrire et d’effectuer d’autres opérations sur tous les entrepôts du compte.

Si vous devez déléguer ces possibilités à un rôle personnalisé de votre compte, vous pouvez lui accorder le privilège MANAGE WAREHOUSES. L’attribution du privilège MANAGE WAREHOUSES équivaut à l’attribution des privilèges MODIFY, MONITOR et OPERATE sur tous les entrepôts du compte.

Les exemples suivants montrent comment vous pouvez déléguer la capacité de gérer des entrepôts à un rôle personnalisé nommé manage_wh_role. L’exemple utilise manage_wh_role pour apporter des modifications à l’entrepôt test_wh, qui appartient à un autre rôle (create_wh_role).

Créez un nouveau rôle qui créera et possédera un nouvel entrepôt, et accordez le privilège CREATE WAREHOUSE à ce rôle :

CREATE ROLE create_wh_role;
GRANT CREATE WAREHOUSE ON ACCOUNT TO ROLE create_wh_role;
GRANT ROLE create_wh_role TO ROLE SYSADMIN;

from snowflake.core.role import Role, Securable

my_role = Role(name="create_wh_role")
my_role_res = root.roles.create(my_role)

my_role_res.grant_privileges(
  privileges=["CREATE WAREHOUSE"], securable_type="ACCOUNT"
)

root.roles['SYSADMIN'].grant_role(role_type="ROLE", role=Securable(name='create_wh_role'))

Créez un deuxième rôle qui gérera tous les entrepôts du compte et accordez-lui le privilège MANAGE WAREHOUSES :

CREATE ROLE manage_wh_role;
GRANT MANAGE WAREHOUSES ON ACCOUNT TO ROLE manage_wh_role;
GRANT ROLE manage_wh_role TO ROLE SYSADMIN;

from snowflake.core.role import Role, Securable

my_role = Role(name="manage_wh_role")
my_role_res = root.roles.create(my_role)

my_role_res.grant_privileges(
  privileges=["MANAGE WAREHOUSES"], securable_type="ACCOUNT"
)

root.roles['SYSADMIN'].grant_role(role_type="ROLE", role=Securable(name='manage_wh_role'))

En utilisant le rôle create_wh_role, créez un nouvel entrepôt :

USE ROLE create_wh_role;
CREATE OR REPLACE WAREHOUSE test_wh
    WITH WAREHOUSE_SIZE= XSMALL;

from snowflake.core import CreateMode
from snowflake.core.warehouse import Warehouse

root.session.use_role("create_wh_role")

my_wh = Warehouse(
  name="test_wh",
  warehouse_size="XSMALL"
)
root.warehouses.create(my_wh, mode=CreateMode.or_replace)

Changez le rôle actuel en manage_wh_role :

USE ROLE manage_wh_role;

root.session.use_role("manage_wh_role")

Bien que le rôle manage_wh_role ne possède pas le rôle test_wh, ce rôle possède le privilège MANAGE WAREHOUSES, ce qui signifie que vous pouvez :

• Suspendre et reprendre l’entrepôt :

  SQLPython

  ALTER WAREHOUSE test_wh SUSPEND;
  ALTER WAREHOUSE test_wh RESUME;
  

  Copy

• Modifier la taille de l’entrepôt :

  SQLPython

  ALTER WAREHOUSE test_wh SET WAREHOUSE_SIZE = SMALL;
  

  Copy

• Décrire l’entrepôt :

  SQLPython

  DESC WAREHOUSE test_wh;
  

  Copy

Vérifier les détails de l’entrepôt dans Snowsight¶

Vous devez utiliser le rôle ACCOUNTADMIN ou un rôle auquel ont été attribués les privilèges d’entrepôt.

Pour vérifier les entrepôts et gérer les détails des entrepôts dans Snowsight, suivez les étapes suivantes :

1. Connectez-vous à Snowsight.

2. Sélectionnez Admin » Warehouses.

Vous pouvez ensuite vérifier la table des entrepôts, rechercher des entrepôts ou filtrer la liste des entrepôts par statut ou par taille.

Par défaut, vous pouvez voir les informations suivantes sur chaque entrepôt :

• Name

• Status, comme Started, Resuming, ou Suspended.

• Size

• Clusters, indiqué par une barre dans la colonne. Vous pouvez survoler la valeur pour voir combien de clusters sont actifs.

• Running, pour savoir combien d’instructions SQL sont exécutées par l’entrepôt.

• Queued, pour savoir combien d’instructions SQL sont en file d’attente pour l’entrepôt.

• Owner, ou le rôle de propriétaire de l’entrepôt.

• Resumed, pour savoir depuis combien de temps l’entrepôt a été repris. Survolez la valeur pour voir la date et l’horodatage exacts dans votre fuseau horaire local.

Vous pouvez également ajouter des colonnes pour voir des détails supplémentaires pour chaque entrepôt dans la table :

• QAS (Scale Factor), la table suivante présente le facteur d’échelle de l’entrepôt utilisé par Query Acceleration Service (QAS). Voir Utilisation du service Query Acceleration.

• Scaling Policy, pour voir la politique de mise à l’échelle définie pour l’entrepôt. Voir Définition de la politique de mise à l’échelle d’un entrepôt multi-clusters.

• Auto Resume, pour voir si la reprise automatique est configurée pour l’entrepôt.

• Auto Suspend, pour connaître la période précédant la suspension automatique pour l’entrepôt.

• Created, pour savoir quand l’entrepôt a été créé. Survolez la valeur pour voir la date et l’horodatage exacts dans votre fuseau horaire local.

Lorsque vous sélectionnez un entrepôt dans la table Warehouses, vous pouvez voir plus de détails :

• La section Warehouse Activity fournit un graphique de la charge de l’entrepôt sur une période donnée, ce qui peut vous aider à comprendre pourquoi une requête s’exécute lentement. Voir Surveillance de la charge de l’entrepôt pour plus de détails.

• La section Details fournit des informations supplémentaires sur votre entrepôt, notamment :

  • Le statut de l’entrepôt.

  • La taille de l’entrepôt.

  • Le nombre maximum et minimum de clusters que l’entrepôt peut utiliser.

  • La politique de mise à l’échelle.

  • Le nombre de tâches qui sont en cours d’exécution et en file d’attente.

  • La période d’inactivité avant la suspension automatique de l’entrepôt.

  • Si l’entrepôt est suspendu, s’il faut reprendre automatiquement l’entrepôt le cas échéant.

  • La dernière fois que l’entrepôt a repris son fonctionnement.

• Vous pouvez utiliser la section Privileges pour voir, accorder et révoquer des privilèges sur l’entrepôt.