Вопросы по теме 'alpakka'
Проблемы с загрузкой/загрузкой файлов в akka-http/akka-streams
Я пытаюсь использовать akka-streams и akka-http и библиотеку alpakka для загрузки/выгрузки файлов на Amazon S3. Я вижу две проблемы, которые могут быть связаны...
Я могу скачивать только очень маленькие файлы, самый большой 8kb.
Я не могу...
744 просмотров
schedule
21.03.2023
Использование Alpakka Cassandra Flow
Я читаю документацию по Alpakka Cassandra здесь
Это позволяет очень легко использовать Cassandra в качестве источника и приемника. но как насчет использования потока.
Под использованием потока я имею в виду, что я не использую Cassandra в...
462 просмотров
schedule
28.11.2022
Alpakka MongoDB — указать тип в MongoSource
В настоящее время я играю с Akka Streams и разъемом Alpakka MongoDB . .
Можно ли указать тип для MongoSource ?
val codecRegistry = fromRegistries(fromProviders(classOf[TodoMongo]), DEFAULT_CODEC_REGISTRY)
private val todoCollection:...
364 просмотров
schedule
03.01.2024
Akka Streams с индексацией Alpakka в ES: имя индекса оценивается только при запуске выполнения
Я написал код с Akka Streams и Alpakka, который считывает данные из Amazon SQS и индексирует события в Elasticsearch. Все работает гладко и производительность потрясающая, но у меня проблема с именами индексов. У меня есть этот код:
class...
152 просмотров
schedule
30.12.2023
Акка Раковина никогда не закрывается
Я загружаю один файл на SFTP-сервер с помощью Alpakka, но после того, как файл загружен и я получил ответ об успешном завершении, приемник остается открытым, как его слить?
Я начал с этого:
val sink = Sftp.toPath(path, settings, false)
val...
96 просмотров
schedule
07.04.2023
Как с помощью Akka Streams узнать, что источник завершен?
У меня есть Alpakka Elasticsearch Sink , который я храню между запросами. Когда я получаю запрос, я создаю Source из HTTP-запроса и превращаю его в Source Elasticsearch WriteMessage , а затем запускаю его с...
564 просмотров
schedule
15.11.2022
Добавление учетных данных в AmazonKinesisAsyncClientBuilder
В другом месте StackOverflow ( ссылка ), доступ к AWS S3 осуществляется следующим образом:
AmazonS3 amazonS3 = AmazonS3Client.builder()
.withRegion("us-east-1")
.withCredentials(new AWSStaticCredentialsProvider(creds))
.build();
Я...
114 просмотров
schedule
10.06.2022
akka.http.scaladsl.model.ParsingException: неожиданный конец составного объекта при загрузке большого файла на S3 с использованием akka http
Я пытаюсь загрузить большой файл (на данный момент 90 МБ) на S3, используя Akka HTTP с разъемом Alpakka S3. Он отлично работает с небольшими файлами (25 МБ), но когда я пытаюсь загрузить большой файл (90 МБ), я получаю следующую ошибку:...
173 просмотров
schedule
03.06.2024