Вопросы по теме 'spring-xd'
Spring-XD: развертывание модулей в определенных контейнерах
Три вопроса относительно развертывания модулей в контейнере Spring XD:
Для определенных источников и приемников необходимо указать, в какой контейнер должен быть развернут модуль. Допустим, у нас много контейнеров на разных машинах, и мы хотим...
469 просмотров
schedule
07.06.2022
весенние рабочие места XD и Кассандра
Я новичок в весне XD...
Я пытаюсь создать задание, которое будет читать CSV-файл и использовать spring-data-cassandra для вставки данных в базу данных Cassandra.
В моем пакетном проекте все в порядке. Я могу упаковать свой пакет и развернуть его...
626 просмотров
schedule
04.05.2022
Можно ли ПРИСОЕДИНИТЬСЯ к нескольким потокам с помощью Spring XD?
Мне нужно определить несколько потоков из нескольких источников, а затем объединить их в один. Прочитав всю документацию Spring XD, я не нашел ни одного предопределенного модуля, который может выполнять объединение (например, на основе скользящих...
699 просмотров
schedule
03.10.2022
SpringXD Job разделяет шаги потока, работающие в отдельных контейнерах в распределенном режиме
Я знаю о поддержке вложенных заданий (XD-1972) и с нетерпением жду этого. Вопрос по поддержке разделенного потока. Есть ли план поддержки выполнения параллельных шагов, как определено в разделить потоки в отдельных контейнерах?
Будет ли это так...
89 просмотров
schedule
22.02.2023
Как загрузить данные с сервера oracle и sql в HAWQ с помощью Spring XD
Привет, у меня есть таблицы в Oracle и SQL Server. Мне нужно загрузить данные с сервера oracle и sql в Pivotal HAWQ с помощью Spring XD. В документации не нашел.
553 просмотров
schedule
11.01.2024
Spring XD — гарантии доставки событий
Когда я создаю поток, состоящий из нескольких модулей, предоставляются ли какие-либо гарантии доставки события каждому модулю. Есть ли возможность повтора событий?
Что делать, если процессорному модулю требуется много времени для обработки одного...
129 просмотров
schedule
17.03.2023
Поддержка подстановочных знаков Activemq в источнике Spring xd jms?
I ', используя activemq 5.9 с пружиной xd 1.1. Хочу подписаться на тему activemq. Итак, я использую источник jms. Activemq поддерживает подстановочные знаки, такие как *,>. > используется для рекурсивного сопоставления любого пункта назначения,...
270 просмотров
schedule
12.05.2022
Spring XD: Написание агрегатора; как выводить асинхронно или хотя бы не 1:1?
Согласно названию, есть ли передовые практики, примеры и т. д. для написания модуля преобразователя агрегатора? У нас есть ситуация, в которой наша агрегация основана на отметке времени в данных, и данные могут поступать не по порядку, с опозданием...
407 просмотров
schedule
04.12.2022
Опрос очереди JMS из источника Spring XD для регулирования
Я пытаюсь использовать источник XD JMS для чтения данных из очереди activeMq и просто записывать их. Мое требование - читать очередь только с определенным интервалом, пытаясь реализовать регулирование. Мне нужен мой поток для обработки только 1...
625 просмотров
schedule
27.03.2022
использование источника http для сохранения файлов (другое расширение) в HDFS с тем же расширением
Мне нужно создать линию передачи данных, где источником является HTTP, а Sink — HDFS для отправки данных и файлов. Проблема в том, что я хочу сохранить файлы с тем же расширением, с которым они изначально были отправлены в источник HTTP.
Я создал...
66 просмотров
schedule
24.11.2022
Пул соединений spring xd для модуля/работы/filejdbc
Мой вариант использования - обработать 50 CSV-файлов и загрузить их в БД MySQL с помощью модуля заданий spring xd filejdbc.
Для этого я настроил пул соединений с источником данных в spring-xd-1.0.0.RELEASE\xd\config\servers.yml, например:...
312 просмотров
schedule
18.04.2022
Фильтровать данные внутри пользовательского модуля процессора?
Я пишу пользовательский модуль процессора, используя класс преобразователя, и для некоторых входных данных я не хочу, чтобы преобразователь генерировал какие-либо выходные данные, как я могу это сделать?
Я пытался вернуть null в методе transform(),...
66 просмотров
schedule
08.03.2024
Как настроить количество параллельных выполнений заданий
Похоже, что количество параллельных выполнений заданий ограничено. Мое наблюдение состоит в том, что среда выполнения Spring XD (режим с одним узлом) выполняет не более 10 заданий одновременно.
Я создал 15 заданий (ожидание1, ожидание2,...),...
113 просмотров
schedule
25.07.2023
Возврат запроса последнего значения в MongoDB в исходном модуле Spring XD
Я хотел бы иметь возможность создать выражение запроса/запроса, которое я могу использовать в исходном модуле SprinXD MongoDB для возврата только последнего вставленного документа.
Кажется, что max-messages-per-poll не помогает ( постраничные...
142 просмотров
schedule
04.07.2022
Spring xd файл как источник не работает в случае потока
Я пытаюсь использовать spring xd для чтения из файла в качестве источника и помещать данные в jdbc , я пробовал пакетное задание filejdbc, используя следующее:
xd:>job create csvtojdbc --definition "filejdbc...
205 просмотров
schedule
24.01.2023
Пользовательский модуль Spring XD с Spring Boot
Как правильно создать модуль Spring XD, который будет использовать дополнительные автоконфигурации загрузки? У меня есть модуль, который упакован с дополнительными загрузочными библиотеками, еще не предоставленными XD. Однако я не вижу, чтобы...
110 просмотров
schedule
30.09.2022
Обработка исключений в потоках Spring XD
Как вы можете создать отказоустойчивый поток Spring XD, который будет продолжать работать правильно после того, как исключение будет вызвано для одного конкретного сообщения (т. е. регистрирует ошибку, но продолжает потреблять следующие сообщения в...
194 просмотров
schedule
19.07.2023
Увеличьте параллелизм в поддерживаемой очереди темы: канал
Я тестировал на SpringXD 1.3.0.RELEASE дублирование сообщений на разные стоки. Моя конфигурация представляет собой кластер из трех узлов, поддерживаемый RabbitMQ в качестве шины сообщений. Мой тест был примерно таким:
Первый случай
stream...
202 просмотров
schedule
01.03.2023
Spring Integration File Splitter, отправляющий файловые маркеры в качестве полезной нагрузки
У меня есть исходный модуль spring xd, который разбивает текстовый файл построчно. Я хотел увидеть имя файла и подсчитать количество строк в файле, поэтому я использую разделитель файлов с файловыми маркерами. Но проблема в том, что если у меня есть...
677 просмотров
schedule
20.09.2022
проблема в весеннем кластере xd при развертывании моего модуля
У меня есть модуль s3-puler, который извлекает файл из s3. В производстве я сталкиваюсь с некоторой проблемой, когда пытаюсь создать поток. Но локальный одиночный узел работает нормально, и я попытался настроить кластер из 3 узлов и 1 узел...
126 просмотров
schedule
02.12.2022
