bartek/tauron-scrapper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix token parsing for InfluxDB

Browse Source
This commit is contained in:
Bartłomiej Pluta
2024-11-14 14:17:37 +01:00
parent 62eb8e51d0
commit c13277ebef
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/consumers/influxdb/index.ts
View File

@@ -1,3 +1,4 @@
import { readFileSync } from "fs";
import { InfluxDB, Point } from "@influxdata/influxdb-client"; import { InfluxDB, Point } from "@influxdata/influxdb-client";
import { Consumer } from "../abstract"; import { Consumer } from "../abstract";
import { InfluxDBConfig } from "./types"; 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) { protected async publish({ databaseURL, apiToken, organization, bucket }: InfluxDBConfig, date: Dayjs, measurement: Measurement) {
const db = new InfluxDB({ const db = new InfluxDB({
url: databaseURL, url: databaseURL,
token: apiToken, token: readFileSync(apiToken, 'utf8'),
}); });
const api = db.getWriteApi(organization, bucket); 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()) .timestamp(date.clone().set('hour', 23).set('minute', 59).set('second', 59).toDate())
.floatField('value', measurement.reading.C); .floatField('value', measurement.reading.C);
hourlyEnergy.forEach(api.writePoint); hourlyEnergy.forEach(p => api.writePoint(p));
api.writePoint(dailyEnergy); api.writePoint(dailyEnergy);
api.writePoint(monthlyEnergy); api.writePoint(monthlyEnergy);
api.writePoint(annualyEnergy); api.writePoint(annualyEnergy);