Kuyruğu yönetme

Makale
11/16/2023

Bu kılavuzda İş Yönlendiricisi kuyruğu oluşturma ve yönetme adımları özetlenmiştir.

Ön koşullar

Etkin aboneliği olan bir Azure hesabı. Ücretsiz hesap oluşturun.
Dağıtılan bir İletişim Hizmetleri kaynağı. İletişim Hizmetleri kaynağı oluşturun.
İsteğe bağlı: İş Yönlendiricisi'ni kullanmaya başlamak için hızlı başlangıcı tamamlayın

Dağıtım ilkesi ve kuyruk oluşturma

İş Yönlendiricisi'nde basit bir kuyruk oluşturmak için SDK'yı kullanarak kuyruk kimliğini, adını ve dağıtım ilkesi kimliğini belirtin. İş Yönlendiricisi kuyruğu oluşturduktan sonra varlığını doğrulayacağı için dağıtım ilkesi önceden oluşturulmalıdır. Aşağıdaki örnekte, İş tekliflerinin Çalışanlar için nasıl oluşturulduğunu denetlemek için bir dağıtım ilkesi oluşturulur.

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"));

Kuyruğu güncelleştirme

İş YönlendiriciSI SDK'sı, yöntem çağrıldığında UpdateQueueAsync mevcut bir kuyruğu güncelleştirir.

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);

Bir kuyruk silme

İş Yönlendiricisi SDK'sını kullanarak bir kuyruğu silmek için kuyruk kimliğini geçiren yöntemini çağırın.DeleteQueue

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());

Dekont

Bir kuyruğu silmek için, kendisine atanmış etkin iş olmadığından emin olmanız gerekir. Ayrıca, herhangi bir sınıflandırma ilkesinde kuyruğa başvuru olmadığından emin olun.

Aracılığıyla paylaş