Перейти к содержанию

Сериализация справочника

Сценарий. При записи элемента справочника Номенклатура отправить JSON-сообщение в Kafka.

Настройка продюсера

Поля табличной части «Объекты метаданных»:

Поле Значение
Тип объекта Справочник.Номенклатура
Имя топика catalog
Тип сериализации Произвольный обработчик
Имя модуля Справочники.Номенклатура
Имя метода Сериализация

Код обработчика

В менеджерном модуле Справочники.Номенклатура:

Функция Сериализация(Объект, Свойства, ТекстЖурнала, Отказ) Экспорт

    Результат = кфкИнтеграция.ПараметрыСообщения();

    Данные = Новый Структура;
    Данные.Вставить("ref",      Объект.Ссылка);
    Данные.Вставить("name",     Объект.Наименование);
    Данные.Вставить("code",     Объект.Код);
    Данные.Вставить("unit",     Объект.ЕдиницаХранения.Наименование);
    Данные.Вставить("deleted",  Свойства.ЭтоУдаление);

    Результат.Данные = Данные;
    Результат.Заголовки.Вставить("ДатаСериализация", ТекущаяУниверсальнаяДата());

    Возврат Результат;

КонецФункции

Что проверить

  1. При записи элемента справочника сообщение появляется в РС Исходящие сообщения со статусом Новое.
  2. После прохода регламентного задания — статус меняется на Выгружено.
  3. В Kafka — сообщение в топике catalog.

Что про ключ

Ключ сообщения

Поле Результат.Ключ не задано — адаптер сформирует ключ автоматически из ключа регистрации. Чтобы управлять партиционированием явно:

Результат.Ключ = Строка(Объект.Ссылка.УникальныйИдентификатор());

Смотрите также