Описание тега itemprocessor
ItemProcessor - это интерфейс для преобразования элементов в приложениях Spring Batch. Учитывая элемент в качестве входных данных, этот интерфейс предоставляет точку расширения, которая позволяет применять бизнес-логику в сценарии обработки, ориентированной на элементы. (Этот тег должен использоваться только с пружинными столбами)
3
ответа
Возврат нескольких предметов из весенней партии ItemProcessor
Я пишу весеннее пакетное задание, и на одном из моих шагов у меня есть следующий код для процессора: @Component public class SubscriberProcessor implements ItemProcessor<NewsletterSubscriber, Account>, InitializingBean { @Autowired private Acc…
02 июн '14 в 23:37
1
ответ
NullPointerException при попытке чтения запросов к базе данных в Spring Batch ItemProcessor
public class TransactionHistoryCsvItemProcessor implements ItemStream, ItemProcessor<TransactionHistory,TransactionHistory>{ @Autowired private TransactionHistoryRepository transactionHistoryRepository; @Autowired private ProductHierarchyRepo…
05 май '20 в 20:15
1
ответ
Раздел Spring Batch не работает с композитным процессором
У меня есть задание раздела Spring Batch. я используюCompositeProcessor, прочитать данные из БД и сохранить эти элементы в CopyOnWriteArrayList. Поскольку среда параллельна, но мойCopyOnWriteArrayList используется для других потоков и смешивания инф…
23 окт '19 в 21:32
0
ответов
Создание новых элементов / строк CSV в Spring Batch Processor в пакетном задании
Резюме: мне нужно экспортировать некоторые CSV-файлы со строками, которые создаются во время пакетного экспорта. У меня уже есть JdbcItemreader для получения данных из моей БД. Процессор форматирует OutputData в требуемый формат. И у меня есть базов…
19 фев '20 в 11:08
1
ответ
Почему исключение в Spring Batch AsycItemProcessor обнаружено методом onSkipInWrite SkipListener?
Я пишу приложение Spring Boot, которое запускается, собирает и преобразует миллионы записей базы данных в новый оптимизированный формат JSON, а затем отправляет их все в тему GCP PubSub. Я пытаюсь использовать для этого Spring Batch, но у меня возни…
29 май '20 в 01:58
1
ответ
Spring Batch @BeforeContext не может выполнить
У меня есть ситуация в весенней партии, когда у меня есть несколько процессоров элементов, которые составляют процессор составных элементов. Мне нужно поделиться некоторыми данными контекста между двумя процессорами на одном этапе. Я нашел рабочее р…
13 авг '20 в 18:10
1
ответ
Spring Batch: многопоточный шаг с AsyncItemProcessor не выполняется параллельно
TL;DR Для файла с миллионом повторений, в котором для каждой строки файла необходимо выполнить значительный объем логики, каков самый быстрый способ прочитать файл и завершить применение логики к каждой строке. Я использовал многопоточный шаг с файл…
08 сен '19 в 11:34
0
ответов
Spring Batch + MongoItemReader, ItemProcessor, MongoItemWriter + не читает все записи
Я использую Spring Batch с базой данных Mongo. Мне нужно получить документы на основе статуса (status =PENDING), написать в очереди Kafka и обновить поле документов с новым статусом (status =FILLED). Так что я использовал MongoItemReader, CompositeI…
03 авг '20 в 19:08
2
ответа
Чтобы отделить класс шагов в весенней партии
Я пытался найти решение, но не могу... ã… ã… Я хочу разделить этапы работы, как показано ниже. step1.class -> step2.class -> step3.class -> done Причина, по которой я так разделен, заключается в том, что мне приходится использовать запросы …
29 мар '20 в 02:44
1
ответ
Как узнать, что это последний элемент в ItemProcessor SpringBatch
У меня есть следующий ItemProcessor, мне нужно знать, является ли этот элемент последним элементом, который отправляет читатель. Это возможно? Другим возможным решением будет ItemReader для отправки списка Line с размером NUMBER_OF_LINES_TO_CALL_WEB…
25 май '21 в 19:27
1
ответ
Spring-batch данные ItemProcessor в виде списка для моделирования
Я использую настраиваемый itemReader для чтения данных из внешнего API отдыха, и он отлично работает. Однако проблема возникает при обработке данных с помощью ItemProcessor в моем классе модели. К сожалению, ответ API - это объект с вложенным в него…
15 авг '21 в 23:17
0
ответов
Как читать из одного CSV-файла и записывать в разные таблицы, разбивая набор столбцов в весеннем пакете
Например Есть файл csv, который имеет идентификатор 20 столбцов, имя, .... Я хочу, чтобы данные первых 10 столбцов были записаны в одну таблицу так же, как данные других 10 столбцов в другой таблице Как добиться этого с помощью ItemReader,ItemWriter…
19 окт '21 в 16:48
1
ответ
Обновление обработанного элемента в Spring Batch
У меня есть приложение Spring Batch, которое использует ItemProcessor для обработки элементов. @Component @StepScope public class MemberProcessor<T> implements ItemProcessor<T, Member> { @Override public Member process(T t) throws Except…
13 янв '22 в 23:20
1
ответ
Динамически передавать имена файлов в FlatFileItemWriter через поток StepBuilderFactory() при использовании ClassifierCompositeItemProcessor в SpringBatch
Я обрабатываю несколько входных файлов с многоформатными строками, используя ClassifierCompositeItemProcessor. Но при использовании StepBuilderFactoryпоток для записи файлов, я не могу передать Resourceимя файла динамически. Имя файла должно быть со…
20 янв '21 в 07:22
0
ответов
Как вызвать функцию postgres из bean-компонента StoredProcedureItemReader с динамическим значением для функции
Я создал и хотел назвать это StoredProcedureItemReader @Beanот моего . Вот мой bean-компонент для чтения элементов хранимой процедуры @Bean public StoredProcedureItemReader<User> jdbcClusterObjectReader(JdbcTemplate jdbcTemplate) throws Except…
02 дек '21 в 11:08
1
ответ
Несколько ItemProcessors и ItemWriters на одном шаге Spring Batch
Могу ли я написать шаг Spring Batch с одним ItemReader и несколькими подшагами, каждый с ItemProcessor , за которым следует ItemWriter? Я пытаюсь добиться чего-то вроде этого: ItemReader ---> item ---> ItemProcessor#1 ---> ItemProcessor#2 |…
29 мар '21 в 10:45
2
ответа
Могу ли я использовать FlatFileItemWriter для записи многоформатного файла в Spring Batch?
Я читаю многоформатный файл, используя FlatFileItemReaderи сопоставление каждой строки с соответствующим типом компонента в ItemProcessorи выполнение обогащения данных. Но когда я пытаюсь записать эти записи в файл, используя FlatFileItemWriter, я н…
11 дек '20 в 06:09
0
ответов
Доступ к параметру задания в Custom ItemProcessor
Я реализую пользовательский ItemProcessor<I, O> в весеннем пакете для обработки данных из Rest API. Я хочу получить доступ к некоторым значениям из jobParameter внутри моего класса ItemProcessor. Любое предложение о том, как это сделать? В Tas…
24 авг '22 в 18:54
0
ответов
Напишите несколько групп/пакетов с заголовком и трейлером, используя весенний пакет.
Я хочу создать файл с финансовыми транзакциями, подобный следующему формату. В основном транзакции группируются по мерчантам и валютам. Каждая группа имеет отдельный заголовок и трейлер. FILE_HEADER MERCHANT_AND_CURRENCY_HEADER TRANSACTION_WITH_AMOU…
02 авг '23 в 17:51