:Colas de recursos en 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

Parámetros de definición:

• MEMORY: tamaño del pool de memoria que se asignará a la cola de recursos que se va a crear. Si toda la memoria del nodo ya se asignó a colas de recursos existentes, no se podrá crear la nueva cola.

• CONCURRENCY: número máximo de consultas simultáneas que admite la cola de recursos por crear. Valor predeterminado: 20. Si el número de consultas simultáneas en la cola supera este límite, las consultas adicionales se bloquean. Las subconsultas iniciadas por el sistema se cuentan como consultas simultáneas, pero no se bloquean. Por ejemplo, si el parámetro CONCURRENCY de una cola se establece en 20 y hay 25 subconsultas simultáneas iniciadas por el sistema, todas las consultas iniciadas por usuarios se bloquearán. Estas se procesarán únicamente cuando el número de subconsultas simultáneas del sistema sea inferior a 20.

• PRIORITY: prioridades de la cola de recursos por crear. Este parámetro especifica las prioridades de programación de CPU y de apropiación de memoria.

• ISOLATE: nivel de aislamiento de memoria de la cola de recursos por crear.

  • El valor predeterminado es 0, lo que indica que no se aplica aislamiento de memoria a la cola. Si el uso de memoria de una cola es bajo, otra cola con mayor prioridad puede apropiar temporalmente su memoria disponible cuando sea necesario.

  • Si establece este parámetro en 1, se aplica un aislamiento suave a la cola. En este caso, ninguna cola con mayor prioridad puede apropiar la memoria disponible de la cola creada.

  • Si establece este parámetro en 2, se aplica un aislamiento absoluto a la cola. En este escenario, ninguna cola con mayor prioridad puede apropiar la memoria disponible de la cola creada, y esta tampoco puede apropiar la memoria disponible de colas con menor prioridad.

• role: usuarios a los que se vincula la cola de recursos creada. Especifique este parámetro con el formato To role [,...]. Las consultas enviadas por estos usuarios se enrutan a la cola creada. Si un usuario está vinculado a varias colas de recursos, el sistema enruta sus consultas a la cola con la prioridad más alta.

Parámetros de configuración:

• target_resource_queue: cola de recursos a la que se enrutan las consultas enviadas por un usuario. También puede configurar un enrutamiento forzado para consultas en el archivo de perfil del usuario.

• resource_queue_max_wait_ms: periodo de tiempo de espera para una consulta bloqueada en la cola debido al límite de concurrencia. El valor predeterminado es 10 segundos.

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;

Para consultar todas sus colas de recursos, ejecute la siguiente instrucción:

show resource queues;

Para consultar la información de uso de las consultas en una cola de recursos específica, ejecute la siguiente instrucción:

show resource queue stat [CURRENT | ALL];