Описание тега apache-camel-aws
1
ответ
Регистрация имени файла во время передачи файла из aws s3 с использованием apache camel
Я новичок в Apache Camel-AWS. Я пишу программу для переноса файла из одной корзины AWS S3 в другую корзину с помощью Apache Camel. Теперь я хочу записать имя файла / объекта, которое выбирается из s3. Не могли бы вы помочь мне с тем же? Ниже мой фра…
25 янв '18 в 11:59
1
ответ
Доступен ли Apache Camel в AmazonMQ?
Отказ от ответственности: я действительно опубликовал это на сервере Fault, и ответы там были: Я голосую, чтобы закрыть этот вопрос как не по теме, потому что мы не поддерживаем AWS. Похоже, что этот вопрос не касается администрирования серверов, се…
22 июн '18 в 15:56
0
ответов
Camel SQS: расширение видимости не работает должным образом
Я использую Camel SQS для потребления сообщений в нашем приложении. Приложение пытается получить до 10 сообщений, но некоторые из этих сообщений могут занять больше времени, чем ожидалось, для обработки (дольше, чем установленный по умолчанию тайм-а…
02 ноя '17 в 00:28
1
ответ
Как использовать контрольную точку Apache Camel AWS-KINESIS для проверки контрольной точки в потоке Kinesis?
Я использую конечную точку AWS-KINESIS в Camel для чтения из потока содержимого AWS Kinesis. Я могу читать сообщения очень хорошо, но как мне проверить сообщение в потоке? В стандартной клиентской библиотеке AWS Kinesis Java есть концепция "Рабочие …
04 май '17 в 11:35
1
ответ
Ошибка загрузки с кодом состояния: 403 SignatureDoesNotMatch, когда multiPartUpload имеет значение true
Я создал простой верблюжий маршрут для опроса файлов в локальном каталоге и загрузки их на сервер Ceph (S3) в моем университете. Я использую Apache Camel 2.20.0 с компонентом Camel-AWS S3, когда я устанавливаю multiPartUpload=false (по умолчанию) в …
05 янв '18 в 01:56
0
ответов
Как скачать ZIP-файл с http с верблюдом?
Я новичок с верблюдом. Я пытаюсь загрузить ZIP-файл, для которого у меня есть http-путь, и пытаюсь сохранить файл в локальной файловой системе. Мне удалось прочитать файл, но вместо того, чтобы прочитать его один раз и загрузить в локальную папку, м…
16 июл '18 в 14:44
1
ответ
Как решить проблему 400 Простой HTTP-запрос был отправлен на проблему порта HTTPS в Apache Camel?
Как разрешить 400 Простой HTTP-запрос был отправлен на проблему порта HTTPS? from: empValidation to: myhost:443/EmpValidation/EmpValidationAPIService rules.getRules().forEach(x->{ final LoadBalanceDefinition lb = from("jetty:http://0.0.0.0:"+rule…
14 май '18 в 22:49
0
ответов
Aws S3 Camel Route в Spring Boot запускается только при запуске приложения
У меня есть загрузочное приложение Spring, которое уже успешно использует Camel FTP. Теперь я пытаюсь реализовать использование Camel S3 для той же цели, что и для FTP: опросить каталог s3 в поисках нового файла, обработать его, затем переместить в …
19 окт '17 в 19:05
1
ответ
Компонент Camel s3 не удаляет файлы из корзины с использованием процессора
Пробуем очень простой верблюжий маршрут: from("aws-s3://javatutorial1232boomiau?amazonS3Client=#s3client&deleteAfterRead=true&fileName=My2.jsp").process(Empty2).log(LoggingLevel.INFO, "Replay Message Sent to file:s3out ${in.header.CamelAwsS3…
31 янв '18 в 06:36
0
ответов
Как отправить сообщение MessageGroupID и MessageDeduplicationID в amazonSQS с помощью camel-aws
Можем ли мы отправить сообщение в очередь FIFO Amazon SQS с использованием синтаксиса Java-DSL: from("..")..to("aws-sqs://testSQSFifo.fifo?amazonSQSClient=#amazonSQSClient); Помните: это очередь FIFO, поэтому для нее нужны MessageGroupID и MessageDe…
06 июл '18 в 19:07
0
ответов
Apache Camel SWF не планирует второе действие в рабочем процессе
Я создал пример приложения Apache Camel SWF на основе Spring Boot. Он работает, как и ожидалось, для первого действия, но, хотя кажется, что он запланировал второе действие, действие не вызывается. Ссылка на пример приложения - https://github.com/kp…
16 янв '18 в 08:26
2
ответа
Разделение массива Json с верблюдом
У меня есть верблюжий маршрут, который принимает объект String из json, вызывает bean-компонент для удаления JSONArray из игроков. from("direct:players").routeId("player_route") .bean(BootstrapStaticParser.class,"getPlayersList") .split(body()) .to(…
01 июл '18 в 16:15
2
ответа
Как прочитать файл S3 только один раз в Apache Camel
Мой старт DSL выглядит примерно так: from("aws-s3://" + s3_bucket_name + "?amazonS3Client=#amazonS3Client&deleteAfterRead=false&fileName=myfile.csv") после этого я преобразую каждую строку в файл JSON и помещаю в локальный каталог. Проблема …
26 ноя '17 в 02:54
1
ответ
Apache Camel: Как транслировать большие файлы из AWS?
У меня есть маршрут следующим образом. Он работает для небольших файлов, но для больших (около 6 ГБ или более) моей программе не хватает памяти. Как мне транслировать контент без сохранения в памяти? public void configure() throws Exception { S3Last…
19 июн '17 в 08:16
0
ответов
Apache Camel читает данные S3 изнутри
Я могу создать приложение верблюда Apache для прослушивания ActiveMQ, из сообщения ActiveMQ я получу имя корзины s3 и имя файла. Эти детали мне нужно перейти к следующему маршруту и прочитать файл и обработать. Я использую весенний ботинок + Apach…
11 апр '19 в 10:46
0
ответов
NoClassDefFoundError: Не удалось инициализировать класс com.amazonaws.http.AmazonHttpClient
Я получаю следующее исключение при настройке верблюжьего маршрута для отправки сообщения в AWS на Red Hat Fuse 7.2.0 с camel-aws. Я выполнил maven-forcer-plugin и разрешил конфликты зависимостей, но все равно получаю то же исключение. Я также пробов…
19 апр '19 в 21:41
0
ответов
NonePoll Enrich внутри цикла DoWhile удаляет только последний файл обмена
Верблюд удаляет только последний файл обмена, а не другие файлы из исходного каталога, когда в цикле loopDoWhile используется pollenrich У меня 2 роутера, процесс и бэкап. После успешного выполнения роутера процесса я хочу переместить все файлы из d…
29 июл '19 в 14:05
0
ответов
Camel SNS - Как использовать асинхронный клиент без блокировки?
В Camel при отправке на конечную точку SNS с использованием AmazonSNSAsync клиент, поведение публикации не меняется, потому что основной SnsPublisher по-прежнему вызывает синхронную блокировку getSNSClient().publish(request) метод. Можно ли публиков…
26 июн '19 в 18:04
2
ответа
Как я могу прочитать все файлы из каталога aws s3 в одном опросе, используя apache-camel
Я пытаюсь достичь: Прочитайте все файлы из каталога s3. Скопируйте все файлы в резервную папку на s3. собрать все содержимое файла в один файл и скопировать его в другой каталог на s3. Но я застрял на первой точке, чтобы прочитать все файлы в одном …
09 июл '19 в 17:22
0
ответов
Тайм-ауты верблюжьего маршрута в конечной точке AWS
У меня есть верблюжий маршрут в kotlin для загрузки файлов из корзины s3, поскольку файлы в корзине не могут быть удалены. Я использую idempotentConsumer, проблема в том, что после нескольких загрузок файлов я начинаю получать: com.amazonaws.http.Am…
16 авг '19 в 19:23