Les files d'attente de ressources isolent et allouent les ressources de calcul entre les déploiements au sein d'un namespace. Chaque namespace inclut une file d'attente par défaut nommée default-queue. Créez des files d'attente personnalisées pour empêcher un seul déploiement ou utilisateur de consommer toutes les ressources disponibles.
Notes d'utilisation
Les files d'attente s'exécutent uniquement en mode exclusif. Les ressources d'une file d'attente ne peuvent pas être préemptées par d'autres files d'attente.
Une fois les ressources d'une file d'attente libérées, elles deviennent disponibles pour de nouveaux déploiements.
En l'absence de file d'attente personnalisée, tous les déploiements s'exécutent dans la file
default-queue.
Assigner une file d'attente à une charge de travail
| Type de charge de travail | Emplacement du paramétrage | Paramètre | Référence |
|---|---|---|---|
| Déploiement | Boîte de dialogue Deploy draft | Deployment Target | Créer un déploiement |
| Cluster de session | Section Standard de la page Create Session Cluster | Deployment Target | Créer un cluster de session |
| Workflow | Panneau Create Workflow | Resource Queue | Gérer les workflows |
Étapes courantes dans la console
Les procédures suivantes commencent toutes par les mêmes étapes de navigation :
Connectez-vous à la console Realtime Compute for Apache Flink.
Repérez l'espace de travail cible et cliquez sur Console dans la colonne Actions.
Dans le volet de navigation de gauche, choisissez O&M > Queue Management.
Ajouter une file d'attente
Règles de nommage des files d'attente
| Règle | Détail |
|---|---|
| Unicité | Doit être unique au sein du namespace |
| Longueur | 32 caractères maximum |
| Caractères | Lettres minuscules, chiffres et traits d'union (-) uniquement |
| Mutabilité | Impossible de modifier le nom après la création |
Procédure
Suivez les étapes courantes dans la console.
Dans le coin supérieur gauche de la page Queue Management, cliquez sur Add queue.
-
Configurez les paramètres de la file d'attente. Les paramètres varient selon que des ressources élastiques sont allouées au namespace.
Namespaces sans ressources élastiques
S'applique lorsque la méthode de facturation de l'espace de travail est le paiement à l'utilisation, l'abonnement ou la facturation hybride, et qu'aucune ressource élastique n'est allouée au namespace.
Paramètre Description Queue Name Saisissez un nom conforme aux règles de nommage des files d'attente. Resources (CU) Nombre d'unités CU disponibles pour la file d'attente. La valeur maximale correspond aux unités CU restantes non allouées dans le namespace. Si le nombre d'unités CU disponibles est insuffisant, reconfigurez les unités CU dans d'autres files d'attente (voir Modifier une file d'attente) ou augmentez les ressources du namespace (voir Reconfigurer les ressources). Namespaces avec ressources élastiques
S'applique lorsque la méthode de facturation de l'espace de travail est la facturation hybride et que des ressources élastiques sont allouées au namespace.
Paramètre Description Queue Name Saisissez un nom conforme aux règles de nommage des files d'attente. Fixed Resources (CUs) Nombre d'unités CU fixes disponibles pour la file d'attente. Si le nombre d'unités CU fixes disponibles est insuffisant, ajustez les ressources en utilisant la méthode de l'espace de travail par abonnement. Consultez Reconfigurer les ressources. Elastic Resources (CUs) Nombre d'unités CU élastiques disponibles pour la file d'attente. La page Queue Management affiche le nombre maximal d'unités CU élastiques pouvant être allouées. Si le nombre d'unités CU élastiques disponibles est insuffisant, ajustez les ressources en utilisant la méthode de l'espace de travail à la demande. Consultez Reconfigurer les ressources. Cliquez sur OK.
Modifier une file d'attente
Ajustez l'allocation des unités CU pour une file d'attente existante lorsque les besoins en ressources évoluent.
Suivez les étapes courantes dans la console.
Repérez la file d'attente cible et cliquez sur Edit dans la colonne Actions.
-
Dans la boîte de dialogue Edit Queue, mettez à jour les valeurs des ressources. Pour les descriptions des paramètres, voir Ajouter une file d'attente.
ImportantLa valeur Resources (CU) ne peut pas être inférieure au nombre d'unités CU actuellement utilisées par la file d'attente.
Cliquez sur OK.
Supprimer une file d'attente
La file d'attente par défaut (
default-queue) ne peut pas être supprimée.Une file d'attente contenant des déploiements en cours d'exécution ne peut pas être supprimée.
La suppression d'une file d'attente référencée par un déploiement provoque une erreur lors du redémarrage de ce déploiement.
Suivez les étapes courantes dans la console.
Repérez la file d'attente cible, cliquez sur Delete dans la colonne Actions, puis cliquez sur OK.
Cas d'utilisation
Isoler les charges de travail par lots : Assignez les déploiements par lots à des files d'attente dédiées pour éviter qu'ils n'accaparent les ressources au détriment des autres tâches.
Prioriser les tâches critiques : Combinez les files d'attente avec la fonctionnalité Workflows (aperçu public) pour définir les priorités de planification des brouillons par lots.
Références
Reconfigurer les ressources – Ajustez les ressources du namespace ou les limites de quota.
Créer un déploiement – Créez des déploiements SQL, JAR ou Python.
Créer un cluster de session – Configurez un cluster de session pour le débogage.
Workflows (aperçu public) – Planifiez et priorisez les déploiements par lots.