:Files de ressources dans ApsaraDB for ClickHouse

-- Create a resource queue.
CREATE RESOURCE QUEUE [IF NOT EXISTS | OR REPLACE] name [ON CLUSTER cluster]
  * {[SET] MEMORY = {number}
  * [, CONCURRENCY = {number}]
  * [, PRIORITY = { LOWEST | LOW | NORMAL | HIGH | HIGHEST }]
  * [, ISOLATE = {number}]
    * }
  * [TO {role [,...] | ALL | ALL EXCEPT role [,...]}]

-- Modify a specified resource queue.
ALTER RESOURCE QUEUE [IF NOT EXISTS | OR REPLACE] name [ON CLUSTER cluster]
  * {[SET] MEMORY = {number}
  * [, CONCURRENCY = {number}]
  * [, PRIORITY = { LOWEST | LOW | NORMAL | HIGH | HIGHEST }]
  * [, ISOLATE = {number}]
    * }
  * [TO {role [,...] | ALL | ALL EXCEPT role [,...]}]  

-- Query a specified resource queue.
SHOW CREATE resource queue name

-- Query the resource queue that you are using.
SHOW CREATE resource queue current

-- Delete a specified resource queue.
DROP resource queue if exists name

Paramètres de définition :

• MEMORY : taille du pool de mémoire à allouer à la file de ressources créée. Si toute la mémoire du nœud a déjà été attribuée aux files de ressources existantes, la création de la file de ressources échoue.

• CONCURRENCY : nombre maximal de requêtes simultanées prises en charge par la file de ressources créée. La valeur par défaut est 20. Si le nombre de requêtes simultanées dans la file de ressources dépasse cette limite, les requêtes supplémentaires sont bloquées. Les sous-requêtes initiées par le système sont comptabilisées comme des requêtes simultanées, mais ne sont pas bloquées. Si le paramètre CONCURRENCY d'une file de ressources est défini sur 20 et que le nombre de sous-requêtes simultanées initiées par le système dans cette file est de 25, toutes les requêtes initiées par l'utilisateur sont bloquées. Le traitement des requêtes initiées par l'utilisateur reprend lorsque le nombre de sous-requêtes simultanées initiées par le système devient inférieur à 20.

• PRIORITY : priorités de la file de ressources créée. Ce paramètre définit les priorités de planification du CPU et de préemption de la mémoire.

• ISOLATE : niveau d'isolation de la mémoire de la file de ressources créée.

  • La valeur par défaut est 0, ce qui signifie qu'aucune isolation de la mémoire n'est mise en œuvre pour la file de ressources créée. Si l'utilisation de la mémoire d'une file de ressources est faible, une file de ressources ayant une priorité plus élevée peut temporairement préempter la mémoire disponible de cette file si nécessaire.

  • Si vous définissez ce paramètre sur 1, une isolation souple est appliquée à la file de ressources créée. Dans ce cas, une file de ressources ayant une priorité plus élevée ne peut pas préempter la mémoire disponible de la file de ressources créée.

  • Si vous définissez ce paramètre sur 2, une isolation absolue est appliquée à la file de ressources créée. Dans ce cas, une file de ressources ayant une priorité plus élevée ne peut pas préempter la mémoire disponible de la file de ressources créée. De même, la file de ressources créée ne peut pas préempter la mémoire disponible d'une file de ressources ayant une priorité inférieure.

• role : utilisateurs auxquels la file de ressources créée est associée. Spécifiez ce paramètre au format To role [,...]. Les requêtes envoyées par ces utilisateurs sont acheminées vers la file de ressources créée. Si un utilisateur est associé à plusieurs files de ressources, le système achemine ses requêtes vers la file de ressources ayant la priorité la plus élevée.

Paramètres de configuration :

• target_resource_queue : file de ressources vers laquelle les requêtes envoyées par un utilisateur sont acheminées. Vous pouvez également configurer un acheminement forcé pour les requêtes dans le fichier de profil de l'utilisateur.

• resource_queue_max_wait_ms : délai d'expiration d'une requête bloquée dans la file de ressources en raison de la limite de simultanéité. La valeur par défaut est de 10 secondes.

CREATE RESOURCE QUEUE IF NOT EXISTS test_queue ON CLUSTER cluster SET 
  MEMORY = 1073741824, CONCURRENCY = 20, ISOLATE = 0, PRIORITY = NORMAL 
    TO default;

CREATE RESOURCE QUEUE IF NOT EXISTS anonymous_queue ON CLUSTER cluster SET 
  MEMORY = 1073741824, CONCURRENCY = 20, ISOLATE = 1, PRIORITY = LOW;

SHOW CREATE resource queue test_queue;

SHOW CREATE resource queue current;

SELECT count (distinct intDiv(number, 10)) FROM numbers(100000) settings target_resource_queue='anonymous_queue';

DROP resource queue if exists test_queue;

DROP resource queue if exists anonymous_queue;

Pour interroger toutes vos files de ressources, exécutez l'instruction suivante :

show resource queues;

Pour interroger les informations d'utilisation des requêtes dans une file de ressources spécifique, exécutez l'instruction suivante :

show resource queue stat [CURRENT | ALL];