Gerenciar uma fila
Este guia descreve as etapas para criar e gerenciar uma fila do JobRouter.
Pré-requisitos
- Uma conta do Azure com uma assinatura ativa. Crie uma conta gratuitamente.
- Um recurso dos Serviços de Comunicação implantado. Crie um recurso dos Serviços de Comunicação.
- Opcional: concluir o guia de início rápido de Introdução ao Roteador de Trabalho
Criar uma política de distribuição e uma fila
Para criar uma fila simples no JobRouter, use o SDK para especificar a ID da fila, o nome e uma ID da política de distribuição. A política de distribuição deve ser criada com antecedência, pois o JobRouter validará sua existência após a criação da fila. No exemplo a seguir, uma política de distribuição é criada para controlar como as ofertas de trabalho são geradas para os Trabalhadores.
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"));
Atualizar uma fila
O SDK do Job Router atualizará uma fila existente quando o UpdateQueueAsync
método for chamado.
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);
Excluir uma fila
Para excluir uma fila usando o SDK do Job Router, chame o DeleteQueue
método que passa a ID da fila.
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());
Observação
Para excluir uma fila, você deve certificar-se de que não há trabalhos ativos atribuídos a ela. Além disso, verifique se não há referências à fila em nenhuma política de classificação.
Comentários
https://aka.ms/ContentUserFeedback.
Em breve: Ao longo de 2024, eliminaremos os problemas do GitHub como o mecanismo de comentários para conteúdo e o substituiremos por um novo sistema de comentários. Para obter mais informações, consulteEnviar e exibir comentários de