diff --git a/src/consumers/influxdb/index.ts b/src/consumers/influxdb/index.ts
index 556006a..51f521a 100644
--- a/src/consumers/influxdb/index.ts
+++ b/src/consumers/influxdb/index.ts
@@ -1,3 +1,4 @@
+import { readFileSync } from "fs";
 import { InfluxDB, Point } from "@influxdata/influxdb-client";
 import { Consumer } from "../abstract";
 import { InfluxDBConfig } from "./types";
@@ -17,7 +18,7 @@ export class InfluxDBConsumer extends Consumer<InfluxDBConfig> {
   protected async publish({ databaseURL, apiToken, organization, bucket }: InfluxDBConfig, date: Dayjs, measurement: Measurement) {
     const db = new InfluxDB({ 
       url: databaseURL,
-      token: apiToken,
+      token: readFileSync(apiToken, 'utf8'),
     });
 
     const api = db.getWriteApi(organization, bucket);
@@ -47,7 +48,7 @@ export class InfluxDBConsumer extends Consumer<InfluxDBConfig> {
       .timestamp(date.clone().set('hour', 23).set('minute', 59).set('second', 59).toDate())
       .floatField('value', measurement.reading.C);
 
-    hourlyEnergy.forEach(api.writePoint);
+    hourlyEnergy.forEach(p => api.writePoint(p));
     api.writePoint(dailyEnergy);
     api.writePoint(monthlyEnergy);
     api.writePoint(annualyEnergy);