Добавьте в конфигурацию объекты подсистемы
Реализуйте обработчики в соответсвии с требованиям к сигнатуре (пример тестового модуля)
// Выполняет обработку задачи в конвейере.
// Может использоваться для выполнения произвольной логики, например, обработки данных.
// В процессе выполнения может сгенерировать исключение (например, для тестирования обработки ошибок).
//
// Параметры:
// ПараметрыЗадачи - Произвольный - входные параметры задачи. Могут быть любого типа, переданы из предыдущего обработчика или при регистрации.
// Кэш - Соответствие - используется для кэширования данных между задачами в рамках одного пакета обработки.
// Например, можно хранить соединение с базой данных, чтобы не открывать его для каждой задачи.
// ЭтоПоследняя - Булево - признак того, что это последняя задача в текущем пакете.
// Можно использовать для освобождения ресурсов (например, закрытия соединения с базой).
//
Функция Обработчик1(ПараметрыЗадачи, Кэш, ЭтоПоследняя) Экспорт
Сообщить("Делаем Обработчик1");
Если ЗначениеЗаполнено(ПараметрыЗадачи) Тогда
ВызватьИсключение "Заполенены параметры....";
КонецЕсли;
СлучайнаяОшибка();
Возврат "" + ПараметрыЗадачи + "/Обработчик1";
КонецФункции
Функция Обработчик2(ПараметрыЗадачи, Кэш, ЭтоПоследняя) Экспорт
Сообщить("Делаем Обработчик2");
Если СтрНайти(ПараметрыЗадачи,"Обработчик1") = 0 Тогда
ВызватьИсключение "не найден Обработчик1";
КонецЕсли;
СлучайнаяОшибка();
Возврат ПараметрыЗадачи + "/Обработчик2";
КонецФункции
Функция Обработчик3(ПараметрыЗадачи, Кэш, ЭтоПоследняя) Экспорт
Если СтрНайти(ПараметрыЗадачи,"Обработчик1") = 0 Тогда
ВызватьИсключение "не найден Обработчик1";
КонецЕсли;
Если СтрНайти(ПараметрыЗадачи,"Обработчик2") = 0 Тогда
ВызватьИсключение "не найден Обработчик2";
КонецЕсли;
Сообщить("Делаем Обработчик3");
СлучайнаяОшибка();
Возврат ПараметрыЗадачи + "/Обработчик3";
КонецФункции
Процедура СлучайнаяОшибка()
Возврат;
ГСЧ = Новый ГенераторСлучайныхЧисел;
Число = ГСЧ.СлучайноеЧисло(0, 100);
Если Число%5 = 0 Тогда
ВызватьИсключение "Случайная ошибка " + Число;
КонецЕсли;
КонецПроцедуры
Создайте элемент справочника "Конвейры обработки задач"
Идентификатор (код) - уникальный идентификатор который будете указывать при регистрации задач
Включен - признак влияет на запуск из рег. задания "(ОЗОН) Конвейры обработки задач"
Количество выбираемых задач - размер выборки для одного цикла запуска
Добавляете свои обработчики указывая:
Метод - полный путь к методу
Количество потоков - количество потоков для этого метода
Размер порции - максимальный размер порции (сообщения с одним ключом всегда попадают в один поток)
Максимальное время выполнения - в случае если фоновое задание потерялось и нет изменений по базе данных мы некоторое время будет проверять состояние задач пачки (нужно указывать максимальное время выполнение пачки)
Максимальное количество ошибок - в случае ошибки обработки задачи будут повторно выполняться при следующих запусках конвейра указанное количество раз
Добавьте регистрацию задач в прикладной код
МассивЗадач = Новый Массив;
Для Сч = 1 По КоличествоЗадач Цикл
НоваяЗадача = озКонвейерОбработкиЗадач.ПараметрыРегистрацииЗадачи();
НоваяЗадача.ПараметрыЗадачи = "";
НоваяЗадача.Ключ = Строка(Сч);
МассивЗадач.Добавить(НоваяЗадача);
КонецЦикла;
озКонвейерОбработкиЗадач.РегистрацияЗадач("озТестМодульДляКонвейераОбработкиЗадач", МассивЗадач, 1000, Истина);
Настройте регламентное задание "Запуск конвейеров"
В случае необходимости добавьте в прикладной код старта конвейера (что бы не дожидаться регламентное задание)
// Запускает конвейер обработки задач в фоновом режиме.
// Создает и выполняет фоновое задание для обработки задач указанного модуля.
//
// Параметры:
// Конвейер - СправочникСсылка.озКонвейерыОбработкиЗадач - конвейер для запуска.
//
// Возвращаемое значение:
// УникальныйИдентификатор - идентификатор запущенного фонового задания или Неопределено, если конвейер уже выполняется.
//
Функция ЗапускКонвейера(Конвейер) Экспорт
