Поток файлов с сервера на клиент с помощью Akka

В принципе, я хочу разрешить пользователю загружать csv-файл с сервера. Предположим, что файл CSV уже существует на сервере. Конечная точка API открывается через GET/export. Как я могу передать файл с HTTP-сервера Akka на клиент? Это то, что я до сих пор ...Поток файлов с сервера на клиент с помощью Akka

Услуги:

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

Маршрут:

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

источник

2016-12-14 perry

Акка-Stream API позволяют создавать объект непосредственно из Source[ByteString, _], так вы можете что-то сделать по строкам

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

Обратите внимание, что таким образом ваш код сервера не понадобится чтобы глотать весь файл CSV в памяти, прежде чем отправлять его по проводу. Содержимое файла будет отправлено в потоке с включенным давлением. Подробнее об этом here.

источник

2016-12-14 19:46:48

Спасибо за это! Следующим шагом для меня является передача файла клиенту, когда строки написаны без необходимости создавать временный файл на сервере. – perry

@perry Можете ли вы поделиться своим подходом с тем, что вы сделали дальше? – oblivion

'def export(): Source [ByteString, _] = Source.fromPublisher (db.stream (things.result.transactionally.withStatementParameters (fetchSize = 1000)))' Где 'вещи' - это TableQuery – perry

Поток файлов с сервера на клиент с помощью Akka

ответ

Смежные вопросы