작업자가 최상의 작업자 배포 모드로 순위가 매겨진 방식을 사용자 지정하는 방법

아티클
11/16/2023

best-worker 배포 모드는 작업을 가장 먼저 처리할 수 있는 작업자를 선택합니다. 두 작업자를 비교하는 식 또는 Azure 함수를 사용하여 작업자 순위를 지정하는 논리를 사용자 지정할 수 있습니다. 다음 예제에서는 사용자 고유의 Azure Function을 사용하여 이 논리를 사용자 지정하는 방법을 보여줍니다.

시나리오: 최상의 작업자 배포 모드에서 사용자 지정 점수 매기기 규칙

큐와 연결된 작업자 간에 제품을 배포하려고 합니다. 작업자는 레이블 및 기술 세트에 따라 점수가 부여됩니다. 점수가 가장 높은 작업자는 첫 번째 제품(BestWorker 배포 모드)을 받아야 합니다.

상황

작업이 생성되고 분류되었습니다.
- 작업에는 다음과 같은 레이블이 연결되어 있습니다.
  - ["CommunicationType"] = "Chat"
  - ["IssueType"] = "XboxSupport"
  - ["Language"] = "en"
  - ["HighPriority"] = true
  - ["SubIssueType"] = "ConsoleMalfunction"
  - ["ConsoleType"] = "XBOX_SERIES_X"
  - ["Model"] = "XBOX_SERIES_X_1TB"
- 작업에는 다음과 같은 WorkerSelectors가 연결되어 있습니다.
  - ["English"] >= 7
  - ["ChatSupport"] = true
  - ["XboxSupport"] = true
작업은 현재 '큐에 대기 중' 상태입니다. 작업자와 일치하기 위해 대기 중인 Xbox 하드웨어 지원 큐에 추가되었습니다.
여러 작업자를 동시에 사용할 수 있습니다.
- 작업자 1은 다음 레이블을 사용하여 만들어졌습니다.
  - ["HighPrioritySupport"] = true
  - ["HardwareSupport"] = true
  - ["Support_XBOX_SERIES_X"] = true
  - ["English"] = 10
  - ["ChatSupport"] = true
  - ["XboxSupport"] = true
- 작업자 2는 다음 레이블을 사용하여 만들어졌습니다.
  - ["HighPrioritySupport"] = true
  - ["HardwareSupport"] = true
  - ["Support_XBOX_SERIES_X"] = true
  - ["Support_XBOX_SERIES_S"] = true
  - ["English"] = 8
  - ["ChatSupport"] = true
  - ["XboxSupport"] = true
- 작업자 3은 다음 레이블을 사용하여 만들어졌습니다.
  - ["HighPrioritySupport"] = false
  - ["HardwareSupport"] = true
  - ["Support_XBOX"] = true
  - ["English"] = 7
  - ["ChatSupport"] = true
  - ["XboxSupport"] = true

기대치

작업자를 채점할 때 다음 동작을 수행하여 첫 번째 제안을 받는 작업자를 선택하려고 합니다.

의사 결정 흐름(위와 같이)은 다음과 같습니다.

작업이 HighPriority가 아닌 경우:
- 레이블이 있는 작업자: ["Support_XBOX"] = true; 점수 100 받기
- 그렇지 않으면 점수 1을 얻습니다.
작업이 HighPriority인 경우:
- 레이블이 있는 작업자: ["HighPrioritySupport"] = false; 점수 1 받기
- 그렇지 않으면 ["HighPrioritySupport"] = true인 경우:
  - 작업자는 콘솔 형식에 특화되어 있나요? -> 작업자가 ["Support_<jobLabels.ConsoleType>"] = true 레이블을 가지고 있나요? true이면 작업자는 점수 200을 얻습니다.
  - 그렇지 않으면 점수 100을 얻습니다.

Azure Function 만들기

프로세스를 더 진행하기 전에 먼저 작업자의 점수를 지정하는 Azure 함수를 정의해 보겠습니다.

참고 항목

다음 Azure 함수는 JavaScript를 사용합니다. 자세한 내용은 빠른 시작: Visual Studio Code를 사용하여 Azure에서 JavaScript 함수 만들기를 참조하세요.

작업자 1에 대한 샘플 입력

{
  "job": {
    "CommunicationType": "Chat",
    "IssueType": "XboxSupport",
    "Language": "en",
    "HighPriority": true,
    "SubIssueType": "ConsoleMalfunction",
    "ConsoleType": "XBOX_SERIES_X",
    "Model": "XBOX_SERIES_X_1TB"
  },
  "selectors": [
    {
      "key": "English",
      "operator": "GreaterThanEqual",
      "value": 7,
      "expiresAfterSeconds": null
    },
    {
      "key": "ChatSupport",
      "operator": "Equal",
      "value": true,
      "expiresAfterSeconds": null
    },
    {
      "key": "XboxSupport",
      "operator": "Equal",
      "value": true,
      "expiresAfterSeconds": null
    }
  ],
  "worker": {
    "Id": "e3a3f2f9-3582-4bfe-9c5a-aa57831a0f88",
    "HighPrioritySupport": true,
    "HardwareSupport": true,
    "Support_XBOX_SERIES_X": true,
    "English": 10,
    "ChatSupport": true,
    "XboxSupport": true
  }
}

샘플 구현:

module.exports = async function (context, req) {
    context.log('Best Worker Distribution Mode using Azure Function');

    let score = 0;
    const jobLabels = req.body.job;
    const workerLabels = req.body.worker;

    const isHighPriority = !!jobLabels["HighPriority"];
    context.log('Job is high priority? Status: ' + isHighPriority);

    if(!isHighPriority) {
        const isGenericXboxSupportWorker = !!workerLabels["Support_XBOX"];
        context.log('Worker provides general xbox support? Status: ' + isGenericXboxSupportWorker);

        score = isGenericXboxSupportWorker ? 100 : 1;

    } else {
        const workerSupportsHighPriorityJob = !!workerLabels["HighPrioritySupport"];
        context.log('Worker provides high priority support? Status: ' + workerSupportsHighPriorityJob);

        if(!workerSupportsHighPriorityJob) {
            score = 1;
        } else {
            const key = `Support_${jobLabels["ConsoleType"]}`;
            
            const workerSpecializeInConsoleType = !!workerLabels[key];
            context.log(`Worker specializes in consoleType: ${jobLabels["ConsoleType"]} ? Status: ${workerSpecializeInConsoleType}`);

            score = workerSpecializeInConsoleType ? 200 : 100;
        }
    }
    context.log('Final score of worker: ' + score);

    context.res = {
        // status: 200, /* Defaults to 200 */
        body: score
    };
}

작업자 1에 대한 출력

앞서 언급한 구현을 통해 지정된 작업에 대해 작업자에게 다음 점수를 얻게 됩니다.

작업자	점수
작업자 1	200
작업자 2	200
작업자 3	1

최상의 작업자 모드에 따라 제안 배포

이제 Azure 함수 앱이 준비되었으므로 라우터 SDK를 사용하여 BestWorkerDistribution 모드의 인스턴스를 만들어 보겠습니다.

var administrationClient = new JobRouterAdministrationClient("<YOUR_ACS_CONNECTION_STRING>");

// Setup Distribution Policy
var distributionPolicy = await administrationClient.CreateDistributionPolicyAsync(
    new CreateDistributionPolicyOptions(
        distributionPolicyId: "BestWorkerDistributionMode",
        offerExpiresAfter: TimeSpan.FromMinutes(5),
        mode: new BestWorkerMode(scoringRule: new FunctionRouterRule(new Uri("<insert function url>")))
    ) { Name = "XBox hardware support distribution" });

// Setup Queue
var queue = await administrationClient.CreateQueueAsync(
    new CreateQueueOptions(
        queueId: "XBox_Hardware_Support_Q",
        distributionPolicyId: distributionPolicy.Value.Id
    ) { Name = "XBox Hardware Support Queue" });

// Create workers
var worker1 = await client.CreateWorkerAsync(new CreateWorkerOptions(workerId: "Worker_1", capacity: 100)
    {
        Queues = { queue.Value.Id },
        Channels = { new RouterChannel(channelId: "Xbox_Chat_Channel", capacityCostPerJob: 10) },
        Labels =
        {
            ["English"] = new RouterValue(10),
            ["HighPrioritySupport"] = new RouterValue(true),
            ["HardwareSupport"] = new RouterValue(true),
            ["Support_XBOX_SERIES_X"] = new RouterValue(true),
            ["ChatSupport"] = new RouterValue(true),
            ["XboxSupport"] = new RouterValue(true)
        }
    });

var worker2 = await client.CreateWorkerAsync(new CreateWorkerOptions(workerId: "Worker_2", capacity: 100)
    {
        Queues = { queue.Value.Id },
        Channels = { new RouterChannel(channelId: "Xbox_Chat_Channel", capacityCostPerJob: 10) },
        Labels =
        {
            ["English"] = new RouterValue(8),
            ["HighPrioritySupport"] = new RouterValue(true),
            ["HardwareSupport"] = new RouterValue(true),
            ["Support_XBOX_SERIES_X"] = new RouterValue(true),
            ["ChatSupport"] = new RouterValue(true),
            ["XboxSupport"] = new RouterValue(true)
        }
    });

var worker3 = await client.CreateWorkerAsync(new CreateWorkerOptions(workerId: "Worker_3", capacity: 100)
    {
        Queues = { queue.Value.Id },
        Channels = { new RouterChannel(channelId: "Xbox_Chat_Channel", capacityCostPerJob: 10) },
        Labels =
        {
            ["English"] = new RouterValue(7),
            ["HighPrioritySupport"] = new RouterValue(true),
            ["HardwareSupport"] = new RouterValue(true),
            ["Support_XBOX_SERIES_X"] = new RouterValue(true),
            ["ChatSupport"] = new RouterValue(true),
            ["XboxSupport"] = new RouterValue(true)
        }
    });

// Create Job
var job = await client.CreateJobAsync(
    new CreateJobOptions(jobId: "job1", channelId: "Xbox_Chat_Channel", queueId: queue.Value.Id)
    {
        Priority = 100,
        ChannelReference = "ChatChannel",
        RequestedWorkerSelectors =
        {
            new RouterWorkerSelector(key: "English", labelOperator: LabelOperator.GreaterThanEqual, value: new RouterValue(7)),
            new RouterWorkerSelector(key: "ChatSupport", labelOperator: LabelOperator.Equal, value: new RouterValue(true)),
            new RouterWorkerSelector(key: "XboxSupport", labelOperator: LabelOperator.Equal, value: new RouterValue(true))
        },
        Labels =
        {
            ["CommunicationType"] = new RouterValue("Chat"),
            ["IssueType"] = new RouterValue("XboxSupport"),
            ["Language"] = new RouterValue("en"),
            ["HighPriority"] = new RouterValue(true),
            ["SubIssueType"] = new RouterValue("ConsoleMalfunction"),
            ["ConsoleType"] = new RouterValue("XBOX_SERIES_X"),
            ["Model"] = new RouterValue("XBOX_SERIES_X_1TB")
        }
    });

// Wait a few seconds and see which worker was matched
await Task.Delay(TimeSpan.FromSeconds(5));
var getJob = await client.GetJobAsync(job.Value.Id);
Console.WriteLine(getJob.Value.Assignments.Select(assignment => assignment.Value.WorkerId).First());

출력

Worker_1 // or Worker_2

Since both workers, Worker_1 and Worker_2, get the same score of 200,
the worker who has been idle the longest will get the first offer.

작업자가 최상의 작업자 배포 모드로 순위가 매겨진 방식을 사용자 지정하는 방법

시나리오: 최상의 작업자 배포 모드에서 사용자 지정 점수 매기기 규칙

상황

기대치

Azure Function 만들기

최상의 작업자 모드에 따라 제안 배포

추가 리소스