val influxDBClient: InfluxDBClientScala = InfluxDBClientScalaFactory
    .create(influxOptions, 10000, OverflowStrategy.backpressure)

  val solar_inverter: Flux = Flux
    .from("electricity")
    .range(
      ZonedDateTime
        .of(
          LocalDate.of(2020, 1, 1).atStartOfDay(),
          ZoneId.of("Europe/Brussels")
        )
        .toInstant,
      ZonedDateTime
        .now(
          ZoneId.of("Europe/Brussels")
        )
        .toInstant
    )
    .filter(
      Restrictions.and(
        Restrictions.measurement().equal("solar_inverter_total_power"),
        Restrictions.value().exists()
      )
    )

  val querySource: Source[String, NotUsed] =
    influxDBClient.getQueryScalaApi().queryRaw(solar_inverter.toString())

  val fp = "./test.txt"

  val filePath = Paths.get(fp)

  val count= querySource
    .log("Source")
    .withAttributes(akkaLoggerAttributes)
    .map( s => ByteString(s + "\n"))
     .runWith(FileIO.toPath(filePath))
    .recover(e => {
      logger.error(e.getMessage)
      throw e
    })

  count onComplete {
    case Success(_) =>
      influxDBClient.close()
      system.terminate()
    case Failure(e) =>
      logger.error(e)
      influxDBClient.close()
      system.terminate()
  }