将 Slick 3.0 查询结果转换为 Akka Streams GraphStage

【问题标题】：Convert Slick 3.0 Query results into a Akka Streams GraphStage将 Slick 3.0 查询结果转换为 Akka Streams GraphStage
【发布时间】：2017-12-14 20:23:13
【问题描述】：

有没有somone使用slick3.0查询mysql并将查询结果转换为AkkaStream GraphStage的示例？

我不想编写自己的自定义 GraphStage（除非绝对必要）。

我很确定应该有某种方法可以将查询结果转换为 GraphStage

【问题讨论】：

标签： scala akka akka-stream slick-3.0

【解决方案1】：

Slick 支持查询结果的流式传输，这是通过遵守 Reactive Streams API 来完成的。

您可以在 Slick 数据库上调用 .stream，然后取回 org.reactivestreams.Publisher。

这可以通过调用 Source.fromPublisher(dbPublisher) 封装到 Akka 流 Source 中。

您可以在docs 中找到更多信息，在this repo 中找到完整示例。

【讨论】：