Skip to content

Commit

Permalink
Fix writing influx data
Browse files Browse the repository at this point in the history
  • Loading branch information
@longzheng
longzheng committed Sep 8, 2024
1 parent 0f35fdb commit d507fad
Showing 1 changed file with 154 additions and 106 deletions.
260 changes: 154 additions & 106 deletions src/helpers/influxdb.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -37,32 +37,41 @@ export function writeSiteMonitoringSamplePoints(
break;
}
case 'perPhase': {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'A')
.floatField('realPower', siteMonitoringSample.realPower.phaseA);

if (siteMonitoringSample.realPower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.tag('phase', 'A')
.floatField(
'realPower',
siteMonitoringSample.realPower.phaseB,
);
siteMonitoringSample.realPower.phaseA,
),
);

if (siteMonitoringSample.realPower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.floatField(
'realPower',
siteMonitoringSample.realPower.phaseB,
),
);
}

if (siteMonitoringSample.realPower.phaseC) {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField(
'realPower',
siteMonitoringSample.realPower.phaseC,
);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField(
'realPower',
siteMonitoringSample.realPower.phaseC,
),
);
}
}
}
Expand All @@ -82,61 +91,79 @@ export function writeSiteMonitoringSamplePoints(
break;
}
case 'perPhase': {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'A')
.floatField(
'reactivePower',
siteMonitoringSample.reactivePower.phaseA,
);

if (siteMonitoringSample.reactivePower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.tag('phase', 'A')
.floatField(
'reactivePower',
siteMonitoringSample.reactivePower.phaseB,
);
siteMonitoringSample.reactivePower.phaseA,
),
);

if (siteMonitoringSample.reactivePower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.floatField(
'reactivePower',
siteMonitoringSample.reactivePower.phaseB,
),
);
}

if (siteMonitoringSample.reactivePower.phaseC) {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField(
'reactivePower',
siteMonitoringSample.reactivePower.phaseC,
);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField(
'reactivePower',
siteMonitoringSample.reactivePower.phaseC,
),
);
}
}
}

switch (siteMonitoringSample.voltage.type) {
case 'perPhase': {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'A')
.floatField('voltage', siteMonitoringSample.voltage.phaseA);

if (siteMonitoringSample.voltage.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.floatField('voltage', siteMonitoringSample.voltage.phaseB);
.tag('phase', 'A')
.floatField('voltage', siteMonitoringSample.voltage.phaseA),
);

if (siteMonitoringSample.voltage.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'B')
.floatField(
'voltage',
siteMonitoringSample.voltage.phaseB,
),
);
}

if (siteMonitoringSample.voltage.phaseC) {
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField('voltage', siteMonitoringSample.voltage.phaseC);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(siteMonitoringSample.date)
.tag('type', 'site')
.tag('phase', 'C')
.floatField(
'voltage',
siteMonitoringSample.voltage.phaseC,
),
);
}
}
}
Expand Down Expand Up @@ -170,32 +197,41 @@ export function writeDerMonitoringSamplePoints(
break;
}
case 'perPhase': {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'A')
.floatField('realPower', derMonitoringSample.realPower.phaseA);

if (derMonitoringSample.realPower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.tag('phase', 'A')
.floatField(
'realPower',
derMonitoringSample.realPower.phaseB,
);
derMonitoringSample.realPower.phaseA,
),
);

if (derMonitoringSample.realPower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.floatField(
'realPower',
derMonitoringSample.realPower.phaseB,
),
);
}

if (derMonitoringSample.realPower.phaseC) {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField(
'realPower',
derMonitoringSample.realPower.phaseC,
);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField(
'realPower',
derMonitoringSample.realPower.phaseC,
),
);
}
}
}
Expand All @@ -215,60 +251,72 @@ export function writeDerMonitoringSamplePoints(
break;
}
case 'perPhase': {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'A')
.floatField(
'reactivePower',
derMonitoringSample.reactivePower.phaseA,
);

if (derMonitoringSample.reactivePower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.tag('phase', 'A')
.floatField(
'reactivePower',
derMonitoringSample.reactivePower.phaseB,
);
derMonitoringSample.reactivePower.phaseA,
),
);

if (derMonitoringSample.reactivePower.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.floatField(
'reactivePower',
derMonitoringSample.reactivePower.phaseB,
),
);
}

if (derMonitoringSample.reactivePower.phaseC) {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField(
'reactivePower',
derMonitoringSample.reactivePower.phaseC,
);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField(
'reactivePower',
derMonitoringSample.reactivePower.phaseC,
),
);
}
}
}

if (derMonitoringSample.voltage) {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'A')
.floatField('voltage', derMonitoringSample.voltage.phaseA);

if (derMonitoringSample.voltage.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.floatField('voltage', derMonitoringSample.voltage.phaseB);
.tag('phase', 'A')
.floatField('voltage', derMonitoringSample.voltage.phaseA),
);

if (derMonitoringSample.voltage.phaseB) {
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'B')
.floatField('voltage', derMonitoringSample.voltage.phaseB),
);
}

if (derMonitoringSample.voltage.phaseC) {
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField('voltage', derMonitoringSample.voltage.phaseC);
influxDbWriteApi.writePoint(
new Point('monitoringSample')
.timestamp(derMonitoringSample.date)
.tag('type', 'der')
.tag('phase', 'C')
.floatField('voltage', derMonitoringSample.voltage.phaseC),
);
}
}

Expand Down

0 comments on commit d507fad

Please sign in to comment.