Gérer une file d’attente

Ce guide décrit les étapes pour créer et gérer une file d’attente du routeur de travaux.

Prérequis

• Compte Azure avec un abonnement actif. Créez un compte gratuitement.
• Une ressource Communication Services déployée. Créez une ressource Communication Services.
• Facultatif : suivez le Guide de démarrage rapide pour commencer à utiliser le routeur de travaux

Créer une stratégie de distribution et une file d’attente

Pour créer une file d’attente simple dans le routeur de travaux, utilisez le kit SDK pour spécifier l’ID de file d’attente, le nom et un ID de stratégie de distribution. La stratégie de distribution doit être créée à l’avance, car le routeur de travaux valide son existence lors de la création de la file d’attente. Dans l’exemple suivant, une stratégie de distribution est créée pour contrôler la façon dont les offres de travail sont générées pour les Workers.

var distributionPolicy = await administrationClient.CreateDistributionPolicyAsync(
    new CreateDistributionPolicyOptions(
        distributionPolicyId: "Longest_Idle_45s_Min1Max10",
        offerExpiresAfter: TimeSpan.FromSeconds(45),
        mode: new LongestIdleMode { MinConcurrentOffers = 1, MaxConcurrentOffers = 10 })
    {
        Name = "Longest Idle matching with a 45s offer expiration; min 1, max 10 offers",
    });

var queue = await administrationClient.CreateQueueAsync(
    new CreateQueueOptions(
        queueId: "XBOX_DEFAULT_QUEUE", 
        distributionPolicyId: distributionPolicy.Value.Id)
    {
        Name = "XBOX Default Queue"
    });

const distributionPolicy = await client.path("/routing/distributionPolicies/{distributionPolicyId}", "Longest_Idle_45s_Min1Max10").patch({
    body: {
        offerExpiresAfterSeconds: 45,
        mode: {
            kind: "longestIdle",
            minConcurrentOffers: 1,
            maxConcurrentOffers: 10
        },
        name: "Longest Idle matching with a 45s offer expiration; min 1, max 10 offers"
    },
    contentType: "application/merge-patch+json"
});

const queue = await client.path("/routing/queues/{queueId}", "XBOX_DEFAULT_QUEUE").patch({
    body: {
        distributionPolicyId: distributionPolicy.body.id,
        name: "XBOX Default Queue"
    },
    contentType: "application/merge-patch+json"
  });

distribution_policy = administration_client.upsert_distribution_policy(
    distribution_policy_id = "Longest_Idle_45s_Min1Max10",
    offer_expires_after = timedelta(seconds = 45),
    mode = LongestIdleMode(min_concurrent_offers = 1, max_concurrent_offers = 10),
    name = "Longest Idle matching with a 45s offer expiration; min 1, max 10 offers"
)

queue = administration_client.upsert_queue(
    queue_id = "XBOX_DEFAULT_QUEUE",
    name = "XBOX Default Queue",
    distribution_policy_id = distribution_policy.id
)

DistributionPolicy distributionPolicy = administrationClient.createDistributionPolicy(new CreateDistributionPolicyOptions(
    "Longest_Idle_45s_Min1Max10",
    Duration.ofSeconds(45),
    new LongestIdleMode().setMinConcurrentOffers(1).setMaxConcurrentOffers(10))
    .setName("Longest Idle matching with a 45s offer expiration; min 1, max 10 offers"));

RouterQueue queue = administrationClient.createQueue(new CreateQueueOptions(
    "XBOX_DEFAULT_QUEUE",
    distributionPolicy.getId())
    .setName("XBOX Default Queue"));

Mettre à jour une file d’attente

Le Kit de développement logiciel (SDK) Job Router met à jour une file d’attente existante lorsque la UpdateQueueAsync méthode est appelée.

queue.Name = "XBOX Updated Queue";
queue.Labels.Add("Additional-Queue-Label", new RouterValue("ChatQueue"));
await administrationClient.UpdateQueueAsync(queue);

await administrationClient.path("/routing/queues/{queueId}", queue.body.id).patch({
    body: {
        name: "XBOX Updated Queue",
        labels: { "Additional-Queue-Label": "ChatQueue" }
    },
    contentType: "application/merge-patch+json"
});

queue.name = "XBOX Updated Queue"
queue.labels["Additional-Queue-Label"] = "ChatQueue"
administration_client.upsert_queue(queue.id, queue)

queue.setName("XBOX Updated Queue");
queue.setLabels(Map.of("Additional-Queue-Label", new RouterValue("ChatQueue")));
administrationClient.updateQueue(queue.getId(), BinaryData.fromObject(queue), null);

Suppression d'une file d'attente

Pour supprimer une file d’attente à l’aide du Kit de développement logiciel (SDK) Job Router, appelez la DeleteQueue méthode qui transmet l’ID de file d’attente.

await administrationClient.DeleteQueueAsync(queue.Value.Id);

await client.path("/routing/queues/{queueId}", queue.body.id).delete();

administration_client.delete_queue(queue.id)

administrationClient.deleteQueue(queue.getId());

Remarque

Pour supprimer une file d’attente, vous devez vérifier qu’aucun travail actif ne lui est attribué. En outre, assurez-vous qu’il n’existe aucune référence à la file d’attente dans les stratégies de classification.