Обработка очередей работ

Статья
03/10/2025

Обработка очереди работ относится к управлению списком рабочих элементов, которые необходимо выполнить в определенном порядке. Этот список содержит информацию о каждом элементе, в том числе имя, приоритет, дату окончания срока действия, состояние и фактическое значение для обработки.

Способы обработки очередей работ:

Обработка очереди работ на основе классического потока в Power Automate Desktop (PAD).
Облачный поток и обработка на основе соединителей.
Обработка на основе облачного потока с поддержкой классического потока.
Использование функций Dataverse для профессиональных разработчиков (только для расширенных сценариев интеграции):
- DataverseВеб-API
- DataverseSDK для .NET

Узнайте больше об инструментах Dataverse для профессиональной разработки: документация для разработчиков Dataverse.

Пошаговые инструкции по обработке

Ниже продемонстрированы три доступных сценария обработки.

Обработка очереди работ на основе классического потока в Power Automate для компьютеров (PAD)

Обработка элементов очереди работ и примеры обновления

Первый шаг к использованию действий очереди работ в Power Automate для компьютеров — это создание очереди работ в среде, в которой вы работаете, и загрузка нескольких элементов очереди с данными, которые будут потребляться на последующих этапах. Элементы очереди можно загружать в очередь работ посредством классического потока, облачного потока или массово (как описано здесь), в результате чего элементы очереди заполняются. В этом примере некоторые элементы очереди были добавлены в очередь работ вручную, чтобы пояснить, как можно использовать действия в Power Automate для компьютеров.

Элементы очереди работ созданы, и поле значения содержит текст в формате JSON, который будет использоваться на последующих этапах в классическом потоке.

Пример потока, который мы будем использовать для демонстрации использования действий очереди работ, имитирует процесс, который будет потреблять элемент очереди работ из облака, обрабатывать данные, содержащиеся в поле значения, и преобразовывать их в пользовательский объект для последующей обработки. Обратите внимание, что использовать JSON или пользовательские объекты в качестве значений для элементов очереди работ не обязательно, но это может быть полезным приемом для организации значений, которые имеют несколько свойств и соответствуют определенной схеме.

Действие Обработать элементы очереди работ используется для указания того, элементы из какой очереди работ требуется потреблять и обрабатывать в классическом потоке. Действие можно настроить так, чтобы оно выбирало очередь работ из списка с помощью стрелки раскрывающегося списка, с передачей переменной с именем очереди. При выполнении это действие работает путем переноса в поток первого (самого старого) элемента из очереди работ, находящегося в состоянии в очереди. Как только элемент очереди начинает обрабатываться в потоке, его состояние автоматически меняется на обработка.

Заметка

Если вы используете переменную для динамического выбора очереди работ, используйте идентификатор очереди работ в качестве входных данных. Идентификатор очереди работ доступен в разделе Дополнительные сведения на странице сведений об очереди работ.

Точка останова (красная точка) была установлена щелчком рядом с действием 3 в потоке, а затем запущена через консоль PAD. Когда процесс приостанавливается в точке останова, переменную WorkQueueItem можно открыть, дважды щелкнув появившееся значение в разделе Переменные потока, и просмотреть все свойства, связанные с обрабатываемым элементом очереди работ.

Заметка

Переменная WorkQueueItem показывает сведения о текущем элементе очереди работ, когда есть оставшиеся элементы для обработки. Если элементов очереди работ для обработки больше нет и действие завершено, отображаются сведения о последнем элементе очереди работы.

В действии 2 потока мы преобразовали возвращаемое значение JSON, доступ к которому в данном случае осуществляется через %WorkQueueItem.Value%, в пользовательский объект. Это нужно потому, что это позволяет разбирать JSON и использовать свойства JSON на следующих этапах потока. В этом гипотетическом случае информация будет использоваться для ввода данных на финансовом портале Farbrikam.
```
{
 "InvoiceId": "I-1006",
 "InvoiceDate": "06/04/2023",
 "AccountName": "Fabrikam",
 "ContactEmail": "invoicing@fabrikam.com",
 "Amount": 1253.78,
 "Status": "Paid",
 "WorkQueueKey": "Vendor Invoices",
 "ComponentState": 0,
 "OverwriteTime": "1900-01-01T00:00:00"
}
```
Например, предположим, что у нас есть требование вводить ИД счета в поле финансовой системы в рамках процесса автоматизации пользовательского интерфейса веб-приложения или классического приложения. Вы можете вызвать это значение с помощью %JsonAsCustomObject.InvoiceId%, чтобы заполнить текстовое поле и нажать кнопку.
Далее этот пример содержит несколько условных операторов после завершения обработки шагов, и данные из пользовательского объекта используются в подпотоке Fabrikam Data Entry. Если процесс выполняется от начала до конца без каких-либо исключений, связанных с системой ввода, действие Обновить элемент очереди работ изменяет состояние элемента очереди работ на Обработано, и поле результат обработки можно использовать для ввода необязательных примечаний. Если поле срок действия оставлено пустым, новый элемент очереди сохраняет значение срок действия элемента, определенное в свойствах очереди работ.

Заметка

Если элементы очереди работ застряли в состоянии обработки из-за сбоя завершения классического потока, используйте облачный поток для получения и обновления элементов очереди работ.

Параметры обработки исключений можно настроить, щелкнув при ошибке в окне конфигурации действия Обновить элемент очереди работ. На вкладке «Дополнительно» доступны три события для настройки. Событие Элемент очереди работ не найден может произойти, если элемент очереди работ будет удален из очереди либо вручную, либо с помощью другого систематического процесса до того, как будет завершена его обработка в PAD. Событие Элемент очереди работ приостановлен может произойти, если автоматизированный процесс или кто-то из пользователей изменит состояние обрабатываемого элемента очереди работ на приостановлено на портале потоков во время обработки элемента очереди. Событие Не удалось обновить элемент очереди работ может произойти, если элемент очереди больше не существует в очереди или переведен в состояние приостановлено. Все вышеперечисленное — это пограничные случаи, которые могут возникнуть. Подробнее об обработке ошибок в классических потоках можно узнать здесь.
Если в ходе обработки данных элемента очереди работ в системе ввода данных была обнаружена какая-либо проблема, элементу в качестве альтернативы может быть присвоен статус универсальное исключение, ИТ-исключение или бизнес-исключение. Эти статусы исключений доступны для использования, когда (или если) ваш сценарий автоматизации соответствует установленным критериям.

Допустим, при обработке элемента очереди наступил сценарий 2. В этом случае элемент очереди помечается как универсальное исключение в очереди-источнике. В зависимости от сценария вы может принять решение менять статус элементов очереди, которые не удалось успешно обработать, на один из альтернативных вариантов статуса. Исходя из этого статуса можно решить, требуется ли вмешательство человека, или построить последующий процесс с логикой, необходимой для обработки каждого статуса исключения.

Шаблон автоматического повтора

Действие Обработка элементов очереди работ в Power Automate Desktop включает расширенный параметр для настройки или переопределения механизма автоматического повтора. Эта функция позволяет указать максимальное количество автоматических повторов для каждого элемента очереди работ, что полезно для обработки ИТ-исключений, таких как временные ошибки сети или временная недоступность системы. Это позволяет компьютеру сохранять элемент и выполнять контролируемые повторные попытки без повторной постановки элемента в очередь, обеспечивая более эффективную и устойчивую обработку очереди работ.

В записи очереди работ в Dataverse можно задать максимальное количество повторных попыток и централизованно управлять им. Это значение по умолчанию применяется ко всем классическим потокам, которые обрабатывают эту очередь работ с помощью действия Обработка элементов очереди работ.

Чтобы переопределить значение по умолчанию на уровне очереди в потоке, перейдите в раздел Дополнительно действия Обработка элементов очереди работ и переключите параметр Переопределение конфигурации автоматического повтора очереди работ. Эта настройка позволяет увеличить или уменьшить максимальное количество повторных попыток или даже отключить механизм повторных попыток, установив счетчик максимального количества равным 0.

При использовании действия Обновление элемента очереди работ с установленным статусом IT exception и максимальным числом автоматических повторов больше 0 система не сразу отправляет обновление оркестратору очереди работ. Вместо этого она повторяет операцию до тех пор, пока не будет достигнуто указанное максимальное количество повторных попыток. Единственное значение, обновляемое в элементе очереди работ, — это retrycount. Это значение увеличивается со второй попытки обновления до тех пор, пока не будет достигнуто максимальное количество автоматических повторов. Кроме того, локальная переменная элемента очереди работ с названием CurrentRetryCount увеличивается на единицу при каждой повторной попытке. Эта переменная позволяет реализовать пользовательскую логику на основе ее значения, если это необходимо.

Поток не будет запрашивать новый элемент при возврате в начало действия Обработка элементов очереди работ, если выполняются следующие условия:

Максимальное количество повторных попыток не достигнуто.
Никаких других обновлений, за исключением ИТ-исключений, не происходит.

При достижении максимального числа повторных попыток действие обновления отправляет обновление оркестратору, изменяя состояние элемента на ИТ-исключение и включая все предоставленные примечания к обработке.

Примеры добавления и повторной постановки в очередь элементов очереди работ из PAD

Действие Добавить элемент очереди работ позволяет пользователям классического потока передавать элементы очереди работ в очередь работ, настроенную на портале потоков. Пакетное создание элементов поддерживается с помощью действия Добавить элементы очереди работ.

В этом примере в каталог ежедневно помещается файл Excel в формате CSV, и каждую его строку необходимо добавлять в очередь работ.

Первые два действия в этом примере процесса сопоставляют папку, в которую помещается ежедневный файл Contoso Invoices.csv. Выполнение процесса начинается с чтения таблицы данных из CSV-файла. Переменная CSVTable содержит данные, которые были импортированы и будут обработаны для создания новых элементов очереди.

Действия 3 и 4 генерируют время истечения срока действия новых элементов очереди после их добавления в очереди работ. Действие 3 фиксирует текущие системные дату и время, а затем с помощью действия %Add to datetime% в данном примере к ним добавляются 7 дней. Результат сохраняется в переменной с именем ExpiryDatetime, которая будет использоваться в действии Добавить элемент очереди работ.

Действие 5 вводит цикл For each, который используется для перебора всех строк данных в импортированной CSVTable; это действие отрисовывает строку данных для текущего обрабатываемого элемента.

Все предыдущие действия в этом примере классического потока теперь включены в задание значений для действия Добавить элемент очереди работ.

В качестве значения параметра очередь работ установлена очередь, в которую мы хотим добавлять новые элементы работ — в данном случае из раскрывающегося списка была выбрана очередь Demo PAD queue.

Для параметра Приоритет оставлено значение по умолчанию Обычный, однако можно также использовать другие варианты — Низкий и Высокий. При попадании в одну и ту же очередь работ элементы очереди с высоким приоритетом обрабатываются в первую очередь, затем обрабатываются элементы с обычным приоритетом и в последнюю очередь с низким.

Параметр Имя задан в виде статического префикса вместе со значением переменной CurrentItem['ID'], которая содержит значение из ячейки идентификатора обрабатываемой строки данных. Это необязательно, но может быть полезно в зависимости от вашего сценария использования.

На основе значений из строки данных в переменной CurrentItem введен параметр Входные данные в формате JSON. Обратите внимание, что имя каждого заголовка было добавлено к переменной currentitem с использованием нотации ['имя заголовка']

Поле Срок действия заполняется переменной типа "дата и время", к которой мы в одном из предыдущих шагов добавили 7 дней. Если оставить это поле пустым, добавляемый элемент очереди работ будет содержать значение срок действия элементов, установленное для очереди работ.

Примечания по обработке обязательными не являются — используйте их по мере необходимости.

При выполнении процесса из каждой строки данных в импортированном CSV-файле создается элемент очереди работ, содержащий статус В очереди, что означает, что он доступен для обработки.

Это лишь некоторые из многих способов использования действий очереди работ в PAD. Не пожалейте времени, чтобы во всем разобраться и творчески подойти к включению очередей работ в свои потоки Power Automate!

Пример повторной постановки элемента в очередь с задержкой

Действие Повторная постановка элемента в очередь с задержкой позволяет пользователям классического потока повторно ставить элементы в очередь и устанавливать период задержки, по истечении которого элемент можно снова выпустить для обработки.

В этом примере имеется очередь работ, загруженная элементами, срок действия которых истекает через 24 часа, но они не могут быть обработаны вовремя, поскольку ИТ-отдел выполняет текущее плановое обслуживание системы, и элементы необходимо повторно поставить в очередь. Техническое обслуживание будет завершено за ночь, поэтому мы будем откладывать каждый элемент очереди на 24 часа, а затем установим срок их действия через 24 часа после периода выпуска.

Первые три действия этого примера процесса — это действия даты и времени. Действие «Получить текущую дату и время» фиксирует системную дату и время на момент запуска действия. Затем мы использовали действие «Добавить в дату и время», чтобы удовлетворить два требования: сначала нам нужно определить время задержки, добавив 24 часа к текущим дате и времени, а затем нам нужно добавить 48 часов к текущим дате и времени в качестве срока окончания действия.

Далее в примере действие «Обработка элементов очереди работ» настроено так, чтобы указывать на загруженную очередь работ, а действие «Повторная постановка элемента в очередь с задержкой» помещается в цикл.

Значения, сгенерированные для задержки и срока действия, теперь можно передать в действие «Повторная постановка элемента в очередь с задержкой». Поле «Элемент очереди работ» заполняется переменной, созданной циклом, — это определяет, какой элемент очереди следует повторно поставить в очередь. Затем мы подключили значения, созданные с помощью действий даты и времени для полей «задержка до» и «срок действия». Параметр «задержка до» является обязательным, но вы можете использовать параметр «срок действия» и «результат обработки» по своему усмотрению.

С помощью этого простого процесса вы можете повторно поставить в очередь все доступные элементы, задержать их на определенное время, а также установить дату истечения срока действия и результат обработки.

Облачный поток и обработка на основе соединителей

Самый простой способ удалить элемент очереди работ из очереди и обработать его заключается в следующем:

Перейдите на Power Automate и выполните вход со своими учетными данными.
В левой части меню выберите Мои потоки.
На панели инструментов выберите + Создать поток, а затем Мгновенный облачный поток.
Укажите имя потока, например Мой первый поток очереди работ, а затем выберите Запустить поток вручную.
Выберите Создать.
После открытия конструктора потоков выберите + Создать шаг, а затем выберите соединитель Microsoft Dataverse.
В списке действий выберите Выполнить связанное действие.

Параметр	Стоимость	Описание:
Имя таблицы	Очереди работ	Имя таблицы очереди работ.
Имя действия	Вывести из очереди	Действие, при котором извлекается следующий доступный элемент из очереди.
ИД строки	[ИД очереди работ]	ИД рабочей очереди (GUID) для очереди, из которой вы нужно выполнить вывод. Вы можете получить это значение, перейдя на страницу сведений об очереди работ вашей очереди и открыв панель Дополнительные сведения.
запрос	запрос	FetchXML в строковом формате JSON, который вы хотите применить к идентификатору очереди работ. Пример: `{ "query": "<fetch mapping=\"logical\" returntotalrecordcount=\"true\" page=\"1\" count=\"1\" no-lock=\"false\">\n<entity name=\"workqueueitem\">\n<filter type=\"and\">\n<condition attribute=\"workqueueid\" operator=\"eq\" value=\"38b14649-cb09-ee11-8f6e-00224804934a\"/>\n<condition attribute=\"statuscode\" operator=\"eq\" value=\"0\"/>\n</filter>\n</entity>\n</fetch>"}`

Заметка

Связанное действие — это действие Dataverse, определенное для конкретной таблицы (очереди работ в нашем примере) и может быть выполнено только для записей этой таблицы. Связанные действия используются платформой для выполнения пользовательской бизнес-логики или операций с определенной записью.

Теперь поток должен выглядеть примерно так.

Выберите Сохранить, а затем проверьте свой поток.
В боковой области тестирования выберите Вручную, Тестировать, Запустить поток, затем Готово.
Если поток был выполнен успешно, вы должны получить аналогичный результат (но с другими идентификаторами).

Затем скопируйте все содержимое JSON из поля body, а затем выберите Изменить в правом верхнем углу окна потока.

Совет

После вывода элемента из очереди работ используйте содержимое JSON элемента в качестве примера схемы для анализа свойств JSON элемента. Это позволяет легко получить доступ к любому свойству элемента, возвращаемому оркестратором очереди работ, в последующих действиях потока.

Добавьте новый шаг, выбрав + Новый шаг и найдите действие под названием Анализ JSON и выберите его.

Поместите указатель мыши в поле Содержимое и выберите свойство body из предыдущего действия.

Затем выберите Создать из образца и вставьте ранее скопированную строку JSON в диалоговое окно и выберите Готово.
Выберите + Новый шаг, а затем выберите соединитель Microsoft Dataverse.
В списке действий выберите Обновить строку.
В поле Имя таблицы выберите таблицу Элементы очереди работ и поместите курсор в поле ИД строки.
В списке Динамическое содержимое теперь у вас будут все поля, доступные в таблице элементов очереди работ.
Выберите Показать дополнительные параметры и затем задайте следующие значения для параметров RowID, Результат обработки, Состояние и причина состояния.

Поле	Стоимость	Details
ИД строки	workqueueitemid	Это значение можно выбрать в диалоговом окне списка динамического содержимого.
Результат обработки	Элемент успешно обработан.
Состояние.	Обработано
Состояние	Обработано

Выберите Сохранить и протестируйте поток еще раз.
Если поток был выполнен успешно, вы должны получить результат, подобный следующему.
Теперь перейдите на страницу сведений об очереди работ и в списке элементов очереди выберите Показать все.
Отфильтруйте поле Состояние для отображения только элементов Обработка и Обработано, чтобы подтвердить, что наши действия по выводу из очереди и обновлению работали должным образом.

Поздравляем, вы только что завершили свой первый сценарий обработки очереди работ!

Обработка на основе облачного потока с поддержкой классического потока

Для этого сценария мы расширяем предыдущий вариант, добавляя этап обработки классического потока.

Вернитесь и отредактируйте Мой первый поток очереди работ.
Добавьте новое действие сразу после действия Анализ JSON и выполните поиск соединителя классических потоков и выполните поток, созданный с помощью Power Automate для компьютеров.
В раскрывающемся списке классических потоков либо выберите и отредактируйте существующий классический поток, либо выберите + Создать новый классический поток и следуйте инструкциям на экране, чтобы создать классический поток и запустить Power Automate для компьютеров. Если вы недостаточно осведомлены о классических потоках, вы можете узнать больше здесь.
После открытия конструктора Power Automate для компьютеров выберите две входные переменные с именем WorkQueueItemValue и WorkQueueItemName, а затем добавьте две выходные переменные с именем ProcessingNotes и ProcessingStatus. У всех этих переменных должен быть задан тип данных Текст.
Укажите значение по умолчанию для переменной WorkQueueItem, чтобы позднее можно было протестировать скрипт локально. Если вы следовали руководству по массовому импорту, у вас должны быть элементы очереди работ в очереди счетов поставщика со значениями в формате JSON. Вот пример одного из используемых значений.
```
{
 "InvoiceId": "I-1006",
 "InvoiceDate": "06/04/2023",
 "AccountName": "Fabrikam",
 "ContactEmail": "invoicing@fabrikam.com",
 "Amount": 1253.78,
 "Status": "Paid",
 "WorkQueueKey": "Vendor Invoices",
 "ComponentState": 0,
 "OverwriteTime": "1900-01-01T00:00:00"
}
```
Теперь Сохраните поток.
На панели действий откройте группу действий Переменные и дважды щелкните действие Преобразовать JSON в пользовательский объект, чтобы добавить его на холст разработки. При этом откроется окно его свойств.
Щелкните значок переменной в поле JSON и выберите переменную WorkQueueItemValue.
Переименуйте созданную выходную переменную из JsonAsCustomObject в VendorInvoice и выберите Сохранить.
Затем добавьте действие Если из группы Условия и настройте его свойства следующим образом:

First operand Operator Second operand

%VendorInvoice['Amount']% Меньше (<) 5000
Выберите Сохранить.
Добавьте еще одно действие из группы Условия с именем Еще между действиями Если и Конец.
Теперь добавьте еще два действия из группы Переменные с именем Задать переменную в действия Если и Еще и задайте для переменных ProcessingNotes и ProcessingStatus следующие значения:

Переменная Стоимость

%ProcessingNotes% Счет уже обработан

%ProcessingStatus% Обработано

First operand	Operator	Second operand
%VendorInvoice['Amount']%	Меньше (<)	5000

Переменная	Стоимость
%ProcessingNotes%	Счет уже обработан
%ProcessingStatus%	Обработано

Скопируйте два действия Задать переменную и вставьте их между действиями Еще и Конец. Затем измените их значения, чтобы они соответствовали следующим:

Переменная	Стоимость
%ProcessingNotes%	Бизнес-исключение: сумма счета превышает 5000 долларов США, что требует утверждения менеджера.
%ProcessingStatus%	Исключение

Теперь поток должен выглядеть примерно так.
Сохраните поток и выполните его, чтобы убедиться, что логика потока работает должным образом.
Вернитесь к редактированию моего первого потока очереди работ.
Выберите вновь созданный (или отредактированный) классический поток из списка, а затем выберите С сопровождением в качестве Режима выполнения.
Введите значения параметров Значение элемента очереди работ и Имя элемента очереди работ, как показано ниже:
Добавьте действие Условие перед действием Обновить строку .
Поместите указатель мыши в поле Выберите значение и выберите Состояние обработки в диалоговом окне списка динамического содержимого.
Поместите указатель мыши в другое поле Выберите значение и введите Обработано в качестве текстового значения.
Перетащите действие Обновить строку в раздел Если да условного действия.
Откройте сведения о действии Обновить строку и замените значения на следующие:
В красном поле Если нет, добавьте другое действие Обновить строку и выберите Элементы очереди работ в качестве имени таблицы.
Затем выберите workqueueitemid в качестве идентификатора строки и откройте Показать дополнительные параметры в разделе выберите Примечания к обработке в качестве значения параметра Результаты обработки.
Выберите Ошибка для параметра Состояние и GenericException для параметра Причина состояния.
Выберите Сохранить и Протестировать, чтобы протестировать автоматизацию в целом и посмотреть выходные данные для действия классического потока.
Чтобы убедиться, что элемент очереди работ обработан, вы можете перейти на страницу сведений об очереди работ, выбрать Показать все в разделе элементов очереди работ и отфильтровать элементы по состоянию Обработано.