Описание тега spring-integration-aws

Расширение интеграции Spring для веб-сервисов Amazon.
0 ответов

Специальные символы в сообщении потребляют Spring-интеграции-AWS

Мы отправляем сообщение в поток kinesis из приложения интеграции с пружиной, но при использовании сообщения через @StreamListener из приложения связывания kinesis мы получаем специальные символы, такие как "f t foo". Пожалуйста, найдите ниже фрагмен…
1 ответ

Проверка с помощью Spring AWS Integration

Согласно примечаниям к выпуску Spring, spring-integration-aws.1.1.0.M1 не включает реализацию DynamoDB MetaDataStore. Все еще ConcurrentMetadataStore Класс, который является хранилищем, основанным на значениях ключей и основанным на реализации, я пр…
1 ответ

Spring boot Не удалось загрузить приложение контекста

Есть приложение Springboot, которое считывает файлы из исходного каталога, используя file-inbound-adapter. Напишите для него тестовые случаи junit. Тестовый пример Junit успешно выполнен в моем локальном затмении. но сталкивается с проблемой при зап…
1 ответ

Как понизить версию AWS SDK в Spring-интеграции-aws

Можно ли в любом случае использовать возможности обработчика массажа, которые являются частью spring -gration-aws-1.1.0-RC1, мы просто понизили версию AWS SDK до aws-sdk-core-1.4.x? Как я хотел бы интегрировать с проприетарным приложением CMS [Hitac…
1 ответ

Невозможно использовать сообщения в пакетном режиме в Kinesis Binder

Я пытаюсь использовать сообщения из потока Kinesis в пакетном режиме я использую compile('org.springframework.cloud:spring-cloud-starter-stream-kinesis:1.0.0.BUILD-SNAPSHOT') Application.yml spring: cloud: stream: bindings: input: group: groupName d…
1 ответ

NPE при попытке опроса S3 с использованием Spring-интеграции-AWS S3StreamingMessageSource

Я пытаюсь опросить хранилище объектов S3 с помощью S3StreamMessageSource, следуя приведенному ниже примеру (в разделе Адаптер потокового входящего канала): https://github.com/spring-projects/spring-integration-aws/tree/v1.1.0.RELEASE @Bean @InboundC…
1 ответ

Обрабатывать ошибки глобально и специфично для канала при чтении потоков Aws Kinesis в Spring Intehration

Я слушаю aws kinesis streams и включаю глобальную обработку ошибок и специально для канала, как показано ниже. Приложение Yml server: port: 8090 eureka.client.enabled: false spring: cloud: stream: bindings: MyInboundChannel: group: myGroup destinati…
1 ответ

Десериализация в Spring Cloud

У меня есть производитель со следующей конфигурацией для типа контента spring: cloud: stream: bindings: eventOut: destination: lab_csi content-type: application/json На стороне потребителя я использую пружинную интеграцию (KinesisMessageDrivenChanne…
1 ответ

S3: Исходящий адаптер для размещения файла в нескольких целевых сегментах

У меня есть приложение с загрузочной пружиной, где я пытаюсь поместить файл в несколько сегментов S3, используя один исходящий адаптер S3. Хотелось бы узнать, возможно ли разместить файл в нескольких корзинах, используя один исходящий адаптер, испол…
1 ответ

Одновременные потребители в контексте весенней интеграции

В приложении Spring для интеграции я использую одновременных потребителей для одновременного использования и обработки нескольких сообщений. В моем приложении я настроил все bean-компоненты на одноэлементный. Я предполагаю, что если я собираюсь расп…
1 ответ

Добавление данных метаданных в объект S3 с использованием исходящего шлюза S3

Написал код для весеннего приложения интеграции aws, которое в настоящее время загружает файлы из исходной папки в целевую корзину S3, используя s3-outbound-gateway. Хотелось бы добавить ниже определенные пользователем метаданные и их значение о фай…
1 ответ

Не удалось запустить связующее устройство кинесис-потока Spring Cloud AWS из-за неправильной инициализации bean-компонента

Я пытаюсь запустить этот простой приемник сообщений Kinesis с помощью следующего кода. Это единственный класс в приложении Я столкнулся с этой ошибкой, так как я обновил до последней версии снимка Kinesis Binder @SpringBootApplication @RestControlle…
1 ответ

Не удается найти расположение схемы интеграции AWS в Интернете

Я не могу найти http://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd под http://www.springframework.org/schema/integration/ Любая помощь?
0 ответов

Spring-Integration-AWS против AWS-Java-SDK для простых операций чтения и записи в S3

Мне нужно получить доступ к AWS S3 для чтения и загрузки некоторых файлов JSON. У меня есть следующие варианты использования: Извлеките файл json, основанный на ObjectId, из S3 и извлеките определенные поля из json. Записать файл json на S3, а иногд…
1 ответ

Выражение локального каталога в адаптере входящего канала s3

Могу ли я иметь выражение локального каталога в s3 входящего адаптера. Мой путь к локальной директории является выражением. Как назначить переменную выражения в атрибуте local-directory? Config details below <int-aws:s3-inbound-channel-adapter id…
1 ответ

aws s3 Spring Монитор модификации файлов интеграции

Я ищу образец монитора модификации файла AWS s3 Spring. Требование: каждый раз, когда файл изменяется из корзины AWS S3, последние изменения должны быть перенесены из экземпляра s3 в EC2. У нас есть событие наблюдения за адаптером входящего файла, н…
1 ответ

Создание ежедневного статистического отчета по интеграции Spring

Иметь весеннее интеграционное приложение, в котором файлы маршрутизируются из папки в сегменты S3 с помощью адаптера s3-outbound-channel-adapter. Если файл успешно обработан, то файл будет перемещен в соответствующее целевое ведро. если есть ошибки,…
1 ответ

Как войти в нуль-канал

При весенней загрузке - интеграции, используйте фильтр, который будет переименовывать файл, если экземпляр успешно переименует только файл, он должен продолжить поток, иначе он будет передан в нулевой канал. Хотите войти в нулевой канал, чтобы увиде…
1 ответ

EnvironmentVariableCredentialsProvider отсутствует у поставщиков при выполнении тестов

У меня есть приложение весенней загрузки, которое использует AWS Kinesis и DynamoDB. Когда я запускаю приложение, я вижу, что AWSCredentialsProviderChain поставляется с EnvironmentVariableCredentialsProvider для чтения AWS_ACCESS_KEY_ID и AWS_ACCESS…
1 ответ

Обработка ошибок пружинной интеграции различных типов

Я использую пружинную интеграцию XML и хочу знать, как лучше всего справляться с обработкой ошибок. Я подключаюсь к s3 используя s3-inbound-streaming-channel-adapter и затем преобразование файла CSV из корзины S3. Возможные ошибки: Исключение преобр…