Streaming to Cassandra with Quill and Akka Streams

Quill.scala

package com.tecsisa.wr

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Source
import io.getquill._
import io.getquill.naming._

import scala.concurrent.ExecutionContext.Implicits.global

object Quill extends App {

  implicit val system = ActorSystem("quill-poc")
  implicit val materializer = ActorMaterializer()

  val db = source(new CassandraAsyncSourceConfig[SnakeCase]("db"))

  case class WeatherStation(
    country: String,
    city: String,
    stationId: String,
    entry: Int,
    value: Int)

  object WeatherStation {
    val persist = quote(query[WeatherStation].insert)
  }

  Source(1 to 10000).runForeach { index =>
    db.run(WeatherStation.persist)(List(WeatherStation("UK", "London", index.toString, index, index)))
  }
  .onComplete { _ =>
    db.close()
    system.terminate()
  }

}