Save csv to postgres after fetching
This commit is contained in:
@@ -18,7 +18,12 @@ object Main extends IOApp {
|
|||||||
dataService <- DataService.of
|
dataService <- DataService.of
|
||||||
fetchService <- FetchService.of
|
fetchService <- FetchService.of
|
||||||
|
|
||||||
fetchCsvList = new FileNameService().generateCurrentHour.flatMap(fetchService.fetchSingleFile)
|
fetchCsvList = new FileNameService().generateCurrentHour
|
||||||
|
.flatMap(fetchService.fetchSingleFile)
|
||||||
|
.flatMap {
|
||||||
|
case Right((name, content)) => postgresService.save(name, content)
|
||||||
|
case Left(error) => IO.raiseError(error)
|
||||||
|
}
|
||||||
fetchCsvTask = scheduler.scheduleTask("Fetch CSV", List(31), fetchCsvList).compile.drain
|
fetchCsvTask = scheduler.scheduleTask("Fetch CSV", List(31), fetchCsvList).compile.drain
|
||||||
|
|
||||||
cleanupTask = scheduler.scheduleTask("Cleanup", List(1), dataService.deleteOldForecasts()).compile.drain
|
cleanupTask = scheduler.scheduleTask("Cleanup", List(1), dataService.deleteOldForecasts()).compile.drain
|
||||||
|
|||||||
Reference in New Issue
Block a user