Skip to content

Instantly share code, notes, and snippets.

@bszwej

bszwej/s3-mongodb-stream-step3.scala

Created August 16, 2017 15:48
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save bszwej/7d97cbe5c0651816859f943ea007e6a9 to your computer and use it in GitHub Desktop.
Save bszwej/7d97cbe5c0651816859f943ea007e6a9 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
s3-mongodb-stream-step3.scala
import akka.stream.scaladsl.{Compression, JsonFraming}
val maximumObjectLength = 16000000
s3Client
.download("backup.bucket", "CookieCollectionBackup")
.via(Compression.gunzip())
.via(JsonFraming.objectScanner(maximumObjectLength))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment