Вопросы по теме 'spring-xd'
Настройка spring-xd для использования oracle в качестве репозитория заданий
Я хочу запустить spring xd с Oracle (11g), который у меня уже есть в моей среде. В настоящее время моей первой заботой является пользовательский интерфейс заданий (в моей базе данных есть существующие данные о выполнении заданий, выполненных...
568 просмотров
schedule
06.07.2022
Загрузка данных в Hadoop 2.2 с помощью Spring-XD
Я пытаюсь создать поток данных из нескольких источников и загрузить его в hdfs.
Для подтверждения концепции я использую установку Hadoop с одним узлом и Spring-XD на одном компьютере. Hadoop был развернут с помощью Ambari и сообщает о...
1144 просмотров
schedule
25.01.2023
Как указать количество модулей внутри составного модуля?
Например, я хотел бы создать составной модуль как «myprocessor»:
xd> module compose myprocessor --definition "processor1 | processor2 | processor3".
Кроме того, я также хотел бы, чтобы число процессоров1, процессор2 и процессор3 составляло...
69 просмотров
schedule
24.05.2023
соединение отклонено при использовании удаленного rabbitmq в качестве приемника весной xd
Чтобы протестировать Spring XD, я следую краткому руководству по потоку в Твиттере на веб-странице проектов. Учебное пособие запускает Spring XD с одним узлом и использует файлы в качестве приемника в определении потока. Я смог запустить этот...
1908 просмотров
schedule
08.12.2022
Как заставить Spring XD развернуть предопределенный набор потоков и кранов при запуске
Есть ли способ запустить набор паров и кранов, которые были определены при запуске нового экземпляра spring xd?
Сценарий таков: мы сделали несколько прототипов в наших системах разработки, но теперь, когда мы хотели бы собрать и выпустить это для...
1117 просмотров
schedule
02.11.2022
Любая концепция глобальной переменной в потоках весной xd?
Сценарий: определение потока в spring xd имеет следующую структуру:
джмс | фильтр | трансформировать | hdfs
В модуле фильтра я запускаю запрос к базе данных, чтобы проверить, применимо ли текущее сообщение для дальнейшей обработки.
Когда...
302 просмотров
schedule
04.09.2023
spring xd source moodule не обрабатывает файлы параллельно
Я работаю над версией Spring XD M7. Я создал источник пара | процессор | раковина. У меня всего 5 файлов в моей исходной папке. Когда мой поток развернут, он обрабатывается последовательно, где у меня есть 3 узла Spring XD Cluster с настроенным...
147 просмотров
schedule
14.12.2022
Развертывание пользовательских модулей spring-xd с помощью Redis
Я работаю над spring xd и gemfire xd, где у меня есть требования, я собираю данные с одного из узлов (локальная файловая система), где запущен xd-admin. Я хочу собрать этот файл и отправить на обработку. Ниже приведено мое определение потока....
389 просмотров
schedule
02.12.2023
Можно ли использовать Spring XD в качестве платформы для комплексных пакетных рабочих процессов Spring?
Spring XD предоставляет платформу для запуска пакетных заданий. Охватывает ли это комплексные рабочие процессы для всех вариантов использования пакетных заданий? Или он предназначен для использования в контексте вариантов использования Spring XD....
945 просмотров
schedule
22.07.2023
Ошибки прокси-сервера Cglib при использовании и данных Spring при переходе с Spring XD M5 на выпуск 1.0.0
Мы переносим ряд пакетных заданий из Spring XD M5 в версию 1.0.0.
При создании и развертывании заданий мы сталкиваемся с проблемой с функциональностью прокси-сервера cglib при автоподключении репозиториев Spring Data (в данном случае для Neo4J)....
1185 просмотров
schedule
17.06.2023
Установка обработчика заголовков http:http-client
Я хотел бы установить заголовок User-Agent при использовании процессора: http-client
Я вижу, что есть опция mappedRequestHeaders, но как использовать для установки User-Agent: например, Mozilla
Либо я что-то упускаю, либо у spring-xd отсутствует...
604 просмотров
schedule
29.01.2023
Spring XD — сбои тестов
Я взял последнюю копию исходного кода XD с github и попытался собрать локальную версию. Когда я запускаю задачу сборки, появляются следующие ошибки. Я запускаю Redis на порту 6379. Не уверен, что чего-то еще не хватает.
мой /etc/hosts выглядит...
153 просмотров
schedule
15.06.2022
Как реализовать RSS-канал в качестве источника в Spring XD
Я хочу загружать RSS-каналы, используя Spring XD для хранения в Hadoop. Я использую следующий пример: https://github.com/spring-projects/spring-xd/wiki/Creating-a-Source-Module Поэтому я создал файл feed.xml в каталоге...
402 просмотров
schedule
19.04.2023
Использование mappedRequestHeaders в Spring XD
Я пытаюсь смоделировать следующий оператор curl
curl -k -H "имя пользователя: ваше имя пользователя API" -H "пароль: ваш пароль API" https://infoconnect1.highwayinfo.govt.nz/ic/jbi/TrafficCameras/REST/FeedService/
Как использовать...
237 просмотров
schedule
09.08.2023
SpringXD: могут ли partitionPath и hdfs-dataset сосуществовать?
Я определил несколько потоков, используя новую опцию partitionPath , чтобы файлы попадали в дневные каталоги в Hadoop:
stream create --name XXXX --definition "http --port=8300|hdfs-dataset --format=avro --idleTimeout=100000...
334 просмотров
schedule
31.01.2023
Адаптер Spring Integration Kafka не выдает сообщение
Я борюсь с этим уже несколько дней.
Я использую адаптер SI для kafka в контейнере Spring-boot.
Я настроил zookeeper и kafka на своей машине. Я также создал производителя консоли, и потребитель протестировал его, и все работает нормально (мне...
3976 просмотров
schedule
11.01.2023
Spring XD - Источник модуля: триггер не работает должным образом
Я немного запутался в том, как модуль «источник: триггер» должен работать в Spring XD. Основываясь на документации, вы можете указать дату начала и фиксированную задержку, и теоретически поток, определяющий триггер, должен начинаться только в это...
379 просмотров
schedule
21.06.2023
Spring XD: источник tcp выводит массив байтов вместо строки? Как вывести обычный текст?
Цель состоит в том, чтобы прочитать данные, передаваемые по сети.
Что касается генерации данных, у меня есть приложение, которое выводит на стандартный вывод. Содержимое этих данных представляет собой строку JSON.
Вот что я делаю (в Linux Mint...
222 просмотров
schedule
24.07.2022
Как сгенерировать несколько сообщений из одного сообщения в spring xd?
Как добиться этого с помощью spring xd?
Входное сообщение: {"key" : "temp", "key1" : "a b c"}
Выходные сообщения (мое требование): {"key" : "temp", "key1" : "a"} {"key" : "temp", "key1" : "b"} {"key" : "temp", "ключ1": "с"}
[Примечание: я...
66 просмотров
schedule
26.03.2023
Передача заголовка http-запроса в RestAPI из SpringXD с использованием процессора http-client
Я пытаюсь использовать API-интерфейс отдыха из моего модуля процессора http-client. Я хотел бы знать, как я могу отправить заголовок запроса на URL-адрес, который я пытаюсь нажать. Без заголовка запроса я получаю 500 Internal Server Error.
Будет...
831 просмотров
schedule
25.05.2022
