Вопросы по теме 'spring-xd'
Как Spring-XD обрабатывает выполнение заданий
Я не могу получить информацию из документации. Может ли кто-нибудь сказать мне, как Spring-XD выполняет задания? Назначает ли он задание определенному контейнеру, и выполняется ли это задание только в контейнере, в котором оно развернуто, или каждое...
2082 просмотров
schedule
14.10.2022
Шина сообщений Spring-xd redis удаляет заголовки из сообщения
Я использую Redis в качестве хранилища сообщений для распределенной среды spring-xd.
Я устанавливаю заголовок сообщения, как показано ниже,
oufinalTreeMapsg1 = MessageBuilder.withPayload(treeMap).setHeader("columnNames", columnNames).build();...
284 просмотров
schedule
03.11.2023
Как указать разные значения параметров в модуле с несколькими экземплярами в потоке, определенном в spring-xd?
Например, я хотел бы определить поток в Spring-XD как «source1 | сток1», а модуль «источник1» имеет опцию: «опция1».
Что мне нравится делать, так это настраивать «source1» так, чтобы он имел несколько экземпляров (это выполнимо в Spring-XD), и в...
83 просмотров
schedule
03.05.2024
Автоматический повтор неудачных заданий в Spring XD
Я ищу стандартный шаблон для автоматического повторного выполнения неудачных заданий в Spring XD заданное количество раз и после указанной задержки. В частности, у меня есть задание чтения элементов HTTP, которое периодически запускается из потока...
894 просмотров
schedule
05.05.2024
Spring XD 1.1.0 — проблемы с подключением к источнику JDBC
Я установил SPRING-XD версии 1.1.0 на машину Centos. Используя xd-singlenode , я хочу подключить его к базе данных SQL Server через источник jdbc и поместить данные в файл.
Я создал несколько потоков следующим образом:
1)xd:>stream create...
294 просмотров
schedule
30.09.2022
SPRING-XD - Получение ошибки: xd-admin не работает, но файл pid существует
У нас есть небольшой основной кластер Hadoop. В этом кластере мы используем spring-xd в качестве инструмента для приема данных.
Пробовал:
Когда следующая команда выполняется с машины spring xd-admin:
[root@host ~]# service...
117 просмотров
schedule
10.11.2022
spring xd теряет сообщения при обработке огромного объема
Я использую spring xd. Мой поток выглядит так, как показано ниже, и запускаю тесты на контейнере с 3 узлами с 1 узлом администратора с кроликом в качестве транспорта.
aws-s3|processor1|http-client|processor2>queue:readyQueue
Я создал внизу...
416 просмотров
schedule
21.11.2022
Как получить метаданные модуля Spring XD из самого модуля
Я создал модуль Spring XD, которому нужен доступ к его ModuleMedatada .
Я могу получить метаданные через ZooKeeperModuleMetadataRepository , но мне еще предстоит узнать, как однозначно идентифицировать работающий модуль.
Учитывая образец...
160 просмотров
schedule
23.05.2024
spring XD: как создать собственный источник http
Мне нужно реализовать собственный источник http с перекрестным происхождением: *.
Как это сделать? Документ Spring XD
Нужны примеры
186 просмотров
schedule
25.11.2022
Облачный поток данных Spring — развертывание микросервисов
Команда, в настоящее время я работаю над spring-xd и использую его в качестве контейнера времени выполнения для анализа данных и заданий пряжи.
Мои вопросы
1) Могу ли я использовать ту же настройку среды, которую я использовал для spring-xd?...
523 просмотров
schedule
25.02.2024
Не удалось прочитать JSON: невозможно десериализовать экземпляр org.springframework.xd.rest.domain.JobExecutionInfoResource[] из токена START_OBJECT
Получение этой ошибки при запуске кода ниже в eclispe
SpringXDTemplate xdTemplate = new SpringXDTemplate(new URI("http://my.ip:9393"));
List<JobExecutionInfoResource> listJobExecutions = xdTemplate.jobOperations().listJobExecutions();
я...
175 просмотров
schedule
05.04.2024
Высочайшая совместимость RabbitMq в качестве шины сообщений для Spring XD 1.3.0.RELEASE
Я пытаюсь выяснить, какую самую высокую версию RabbitMq я могу использовать с Spring XD 1.3.0.RELEASE.
В основном мы используем Rabbit в качестве шины сообщений в Spring XD. Также мы используем его как источник или приемник (пользовательские...
23 просмотров
schedule
17.11.2022