У меня есть очередь в формате JSON в RabbitMQ, и я хотел бы получить некоторые данные, которые фиксируют некоторые условия в StreamSets (используя селектор потоков), а затем сохранить в новой базе данных (JDBC Producer) определенное значение. Как написать конкретное значение после условий и отправить в базу данных?
Судя по вашей конвейерной диаграмме, вы пытаетесь установить значения полей, необходимые для базы данных. Вы должны иметь возможность сделать это в самом JDBC Producer — настройте сопоставление полей и столбцов.
На самом деле вы можете использовать для этого компонент наборов потоков по умолчанию с именем Expression Evaluator. Вы добавляете или перемещаете любые поля с ним.
Ссылка на документацию: оценщик выражений потоков
