Есть таблица sql
Есть ЗУП
Есть 1С шина

Необходимо из sql формировать сообщения и отправлять в ЗУП

Сейчас сделал схему. Источник = Таймер
После sqlconnector
В нем пишу запрос к таблице и добавляю в сообщение

В итоге в сообщение вся выборка из таблицы.

А хотелось бы в цикле формировать сообщения, чтобы было 1 запись из таблицы = 1 сообщение.

Но как это сделать понять не могу

Сделайте запрос в цикле

(0) ПрограммныйИсточник

(2) Не понимаю, как он мне может помочь.
Схема какая будет в итоге и где будет запрос к таблице и формирование сообщения?

Сейчас: Таймер - sqlconnector - Канал1СПриемник - ГруппаУчастников

В sqlconnector есть "обработчик сообщения", там и заполняется сообщение из выборки

Разместить ПрограммныйИсточник после sqlconnector я не могу.
В самом "ПрограммныйИсточник" нет обработчика чего либо.
Примеры нашел только при работе с http сервисом, который будто бы и является источником формирования сообщений.

(1)  В sqlconnector в обработчике который там доступен в параметрах уже есть сообщение.

Т.е. я думал, может в этом обработчике сделать свои сообщения.
пер МоеСообщение = Новый СообщениеИнтеграции()
МойСИ.ОтправитьСообщениеВУзлы(МоеСообщение,МойСИ.Схема.Узлы.???)

Вот вместо ??? должен быть доступен узел, но при моей схеме он не доступен.

(0) Любопытства ради, а зачем вам формировать отдельные сообщения (кроме логики маршрутизации)? По идее Шина достаточно большие объекты может пропихнуть в очередь сервиса интеграции в 1С.

По таймеру делать запрос к sql источнику то еще извращение

Если хочется правильно - триггер на insert/update/delete
По нему кидать записи в отдельную табличку c id

По таймеру забирать минимальный id, создавать одно сообщение, удалять запись
Следующий вызов заберет следующую и новое сообщение

(5) начальству так захотелось.
(6) Схема в шине по сути останется той же как я понимаю, только в ОбработкаСообщения после чтения 1 записи - эту запись нужно будет еще удалить. Спасибо, интересный вариант.

поставьте kafka, там есть Confluent REST Proxy for Apache Kafka