Skip to content

Instantly share code, notes, and snippets.

Created Sep 24, 2018
What would you like to do?
the description for this gist
class S3AlpakkaService()(implicit as: ActorSystem, m: Materializer) extends S3Conf {
private val s3Client: S3Client = S3Client(credentialsProvider, region)
def sink(fileInfo: FileInfo): Sink[ByteString, Future[MultipartUploadResult]] = {
val fileName = UUID.randomUUID().toString + ".tmp"
val key = s"alpakka/${fileName}"
s3Client.multipartUpload(bucketName, key)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment