add MinerData().as_json()

This commit is contained in:
UpstreamData
2022-08-24 15:17:36 -06:00
parent ee2698be50
commit 83a7d8c60f

View File

@@ -16,6 +16,7 @@ from typing import Union, List
from dataclasses import dataclass, field, asdict from dataclasses import dataclass, field, asdict
from datetime import datetime, timezone from datetime import datetime, timezone
import time import time
import json
from .error_codes import X19Error, WhatsminerError, BraiinsOSError from .error_codes import X19Error, WhatsminerError, BraiinsOSError
@@ -177,6 +178,11 @@ class MinerData:
def asdict(self): def asdict(self):
return asdict(self) return asdict(self)
def as_json(self):
data = self.asdict()
data["datetime"] = str(int(time.mktime(data["datetime"].timetuple())))
return json.dumps(data)
def as_influxdb(self, measurement_name: str = "miner_data"): def as_influxdb(self, measurement_name: str = "miner_data"):
tag_data = [measurement_name] tag_data = [measurement_name]
field_data = [] field_data = []