Есть ли способ прочитать все объекты из данной корзины 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