Správa fronty

Tento průvodce popisuje kroky pro vytvoření a správu fronty směrovače úloh.

Požadavky

• Účet Azure s aktivním předplatným. Vytvoření účtu zdarma
• Nasazený prostředek komunikační služby. Vytvořte prostředek komunikační služby.
• Volitelné: Dokončení rychlého startu pro zahájení práce se směrovačem úloh

Vytvoření distribučních zásad a fronty

Pokud chcete vytvořit jednoduchou frontu ve směrovači úloh, použijte sadu SDK k zadání ID, názvu a ID distribuční zásady. Zásady distribuce musí být vytvořeny předem, protože směrovač úloh ověří jeho existenci při vytvoření fronty. V následujícím příkladu se vytvoří zásada distribuce, která určuje, jak se nabídky úloh generují pro pracovní procesy.

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

Aktualizace fronty

Sada SDK směrovače úloh při volání metody aktualizuje existující frontu UpdateQueueAsync .

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

Odstranění fronty

Pokud chcete odstranit frontu pomocí sady SDK směrovače úloh, zavolejte metoduDeleteQueue, která předává ID fronty.

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

Poznámka:

Pokud chcete odstranit frontu, musíte se ujistit, že k ní nejsou přiřazené žádné aktivní úlohy. Kromě toho se ujistěte, že fronta neobsahuje žádné odkazy na žádné zásady klasifikace.