CODEWITHSUNDEEP
scalaakkaakka-streamakka-http
perry
perry

Reputation: 85

Streaming file from server to client using Akka

Basically I want to allow a user to download a csv file from the server. Assume the CSV file already exists on the server. A API endpoint is exposed via GET /export. How do I stream the file from Akka HTTP server to client? This is what I have so far...

Service:

def export(): Future[IOResult] = {
    FileIO.fromPath(Paths.get("file.csv"))
      .to(Sink.ignore)
      .run()
}

Route:

pathPrefix("export") {
  pathEndOrSingleSlash {
    get {
      complete(HttpEntity(ContentTypes.`text/csv`, export())
    }
  }
}

Upvotes: 5

Views: 2427

Answers (1)

Stefano Bonetti
Stefano Bonetti

Reputation: 9023

The Akka-Stream API allow you to create an entity directly out of a Source[ByteString, _], so you can do something along the lines of

pathPrefix("export") {
  pathEndOrSingleSlash {
    get {
      complete(HttpEntity(ContentTypes.`text/csv(UTF-8)`, FileIO.fromPath(Paths.get("file.csv")))
    }
  }
}

Note that this way your server code will not need to ingest the whole CSV file in memory before sending it over the wire. The file contents will be sent over in a backpressure-enabled stream. More on this here.

Upvotes: 6

Related Questions