Передавайте типизированную запись с ID задачи, исходными данными и необходимыми метаданными. Результат обогащения должен сохранять тот же ID и явный статус ошибки.
Что передавать между стадиями обогащения данных
Передавайте типизированную запись с ID задачи, исходными данными и необходимыми метаданными. Результат обогащения должен сохранять тот же ID и явный статус ошибки.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
Условие
Первая стадия pipeline читает события, вторая дополняет их сведениями из справочника. Какие поля нужны в канале между стадиями и как не потерять связь с исходной задачей?
Ответ
Передавайте типизированную запись с ID задачи, исходными данными и необходимыми метаданными. Результат обогащения должен сохранять тот же ID и явный статус ошибки.
Не передавайте неструктурированный набор значений, зависящий от скрытых соглашений. Зафиксируйте владение изменяемыми данными: копируйте payload или запретите изменение после отправки. Ограниченная ёмкость канала создаёт backpressure. Определите отмену, обработку ошибок и закрытие каналов; эти обязанности нельзя возлагать на случайного получателя.