Вопросы по теме 'spring-xd'
Spring XD — конфигурация источника почты — как указать пароль
Я создал почтовый поток с помощью следующей команды -------
stream create --name mailstream --definition "mail --host=imap.gmail.com [email protected] --password=my password | file --dir=/tmp/gmailData" --deploy
См....
757 просмотров
schedule
07.06.2023
Поток SpringXD с исходным кодом Tail снова и снова считывает ВСЕ строки в файле, а не только последние n строк.
stream create --name TailTest --definition "tail --name=/Users/name/Documents/SpringXD/PoC/input/Try.txt --outputType=text/plain --lines=1 |file --name=output --dir=/Users/name/Documents/SpringXD/PoC/output --mode=APPEND" --deploy
Здесь я вижу,...
190 просмотров
schedule
23.08.2022
Загрузка данных в Hadoop с помощью spring xd
Я пытаюсь создать поток между источником HTTP и приемником HDFS. Мои springXD и HDFS установлены на разных машинах**, но я могу успешно запустить команду hadoop fs ls / .
После создания и развертывания потока, когда я публикую данные, используя:...
2031 просмотров
schedule
17.06.2022
spring-xd как использовать исходный текст: строка чтения файла одна за другой
У меня есть поток, который просматривает вывод нескольких файлов в каталоге, обрабатывает данные и помещает их в HDFS. Вот моя команда создания потока:
stream create --name fileHdfs --definition "file --dir=/var/log/supervisor/...
1636 просмотров
schedule
24.06.2022
Парсер SpringXD JSON для Oracle DB
Я пытаюсь использовать SpringXD для передачи некоторых данных метрик JSON в базу данных Oracle.
Я использую этот пример отсюда: Пример SpringXD
Выполняется HTTP-вызов: EarthquakeJsonExample
Моя оболочка cmd.
stream create earthData...
261 просмотров
schedule
25.02.2023
Задания удаляются из реестра при уничтожении Spring XD
Я использую Spring XD как один узел для своей среды Sandbox с базой данных MySQL для пакетных таблиц. Если я убью -15 процесс Spring XD, то все текущие определения для моих заданий и потоков будут потеряны (в случае заданий XD_JOB_REGISTRY,...
306 просмотров
schedule
26.12.2022
Использование пользовательского ObjectMapper для преобразования Spring XD Json в Java
Есть ли простой способ преобразовать полезную нагрузку JSON в объект Java с помощью пользовательского ObjectMapper (Jackson) или мне нужно предоставить собственный преобразователь типов. Я знаю, что мог бы использовать процессор, но как-то было бы...
321 просмотров
schedule
22.09.2023
Исправления документации сайта проекта Spring XD
Как я могу отправить исправления документации на сайт проекта Spring XD ? Существует ли репозиторий GitHub, принимающий pull? -запросы на эти исправления?
49 просмотров
schedule
13.07.2022
Spring XD - конфигурация приемника почты для Outlook
Я пытаюсь настроить почтовый приемник Spring XD для отправки сообщений в учетную запись Outlook. Это мое определение потока:
stream create outlookMailSink --definition "http | mail --to='\"[email protected]\"' --host=outlook.office365.com...
566 просмотров
schedule
22.05.2022
POST для /jobs/executions не отвечает идентификатором выполнения?
Я интегрировал свое приложение с Spring XD через REST API. У меня есть определение задания, настроенное и развернутое для каждого источника данных (мой модуль связан с jdbc), а затем запускаю определенные задания, используя соответствующее...
189 просмотров
schedule
08.08.2022
Spring XD - не удалось найти модуль с именем
У меня есть несколько пользовательских модулей, которые я использую в Spring XD. Я могу без проблем использовать «загрузку модуля» при развертывании XD с одним узлом, но при работе в распределенном режиме у меня есть следующее исключение:...
787 просмотров
schedule
12.06.2022
Обходной путь для XD-2772: нет проверки упаковки модуля во время загрузки модуля
Я создал собственный модуль и зарегистрировал его, как указано в документе Spring-XD. Во время развертывания потока я получаю аналогичную ошибку:
Mar 02, 2015 10:45:48 PM org.springframework.shell.core.SimpleExecutionStrategy invoke
SEVERE:...
253 просмотров
schedule
01.07.2023
Запуск задания API Spring XD Rest с ответом jobParameters на «jobParameters» не распознается как внутренняя или внешняя команда
У меня уже развернуто задание Spring XD, которое ожидает 2 jobParameter s ( absoluteFilePath и fileName ). На самом деле это задание запускается потоком JMS, вывод которого предоставляет эти 2 jobParameter в формате JSON, и это работает...
546 просмотров
schedule
06.07.2022
Необходим ли Zookeeper для одного узла XD?
Этот вопрос относится к выпуску XD 1.1.2.RELEASE. Я новичок в XD, поэтому, пожалуйста, простите, если это глупый вопрос.
В документации сказано только, что XD не поставляется с Zookeeper, и я понял, что это будет необходимо только тогда, когда я...
305 просмотров
schedule
11.10.2023
Инкрементное пакетное задание Spring XD
Я создал пакет заданий для извлечения данных из файла csv в jdbc с использованием модуля filejdbc, он работал правильно, но когда я запланировал запуск пакета каждые 5 минут, он не работал с концепцией инкрементной загрузки, он снова загружал все...
160 просмотров
schedule
25.02.2024
spring xd как получить файл из источника s3 или s3
Я пытаюсь создать поток spring xd для чтения файла с s3, это http-ссылка с amazon s3. Как это сделать весной xd для чтения файла http txt в s3. в настоящее время я отбрасываю файл в /tmp/filetest, он работает с потоком ниже. Я хочу получить файл по...
101 просмотров
schedule
04.07.2023
Spring Integration AWS — S3-Inbound-Adapter — deleteSourceFiles и файлы резервных копий
Нужно удалить файлы после прочтения из ведра S3, вариант не нашел. Как удалить исходный файл после чтения файла из корзины S3 и как сделать резервную копию файлов после его успешного чтения?
Есть ли способ, которым S3-Inbound-Adapter выводит...
654 просмотров
schedule
25.03.2023
SpringXD не может найти классы, присутствующие в библиотеке Uber Jar.
Я создал пользовательский модуль в Spring XD, в котором я запускаю Oracle DB и кеширую результаты с помощью ehcache. Помимо jar-файлов, присутствующих в xd/lib, я использую «ehcache-2.9.0.jar и ojdbc6-11.1. 0.7.0.jar" в моем модуле. Я создал банку...
257 просмотров
schedule
01.04.2023
Конфигурация Spring XD Java не загружает ресурс xml
Я использую Spring XD для создания потокового twittersearch, затем подключаюсь к моему процессору твитов, а затем подключаюсь к журналу.
Я использовал класс конфигурации Java без проблем, затем я хотел добавить applicationContext.xml в свой класс...
260 просмотров
schedule
24.08.2022
Экстернализация файла свойств и файла контекста приложения — пользовательский модуль Spring XD
Есть ли способ, которым мы можем экстернализировать файлы контекста приложения и свойств при развертывании пользовательского модуля spring-xd? Когда я развертываю модуль, я просто вижу банку внутри в xd/custom-modules/processor. Однако стандартные...
139 просмотров
schedule
02.03.2024
