alpakka: поток объектов из ведра s3 - PullRequest
0 голосов
/ 29 мая 2020

Есть ли способ прочитать все объекты из данной корзины s3 как s3 Source с помощью alpakka? Мне нужно что-то вроде этого (псевдокод):

S3.readObjects(bucket)
  .map(object => parseJson(object.getContent))
  ...

Интеграция alpakka s3 предоставляет два источника: S3.listBucket(bucket) и S3.download(bucket, key), но мне не удалось объединить эти 2 вместе для достижения желаемого поведения. Я совершенно новичок в потоках akka, следует ли комбинировать эти два или есть другой способ?

Я использую akka-stream 2.5.31 и alpakka 2.0.0

...