Mirror/AI-on-the-edge-device
1
0
Fork 0
mirror of https://github.com/jomjol/AI-on-the-edge-device.git synced 2025-12-31 21:59:22 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update interface_influxdb.cpp

Browse Source
This commit is contained in:
jomjol
2023-01-29 13:38:16 +01:00
parent 08c0ff0fed
commit 12925f5f95
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
code/components/jomjol_influxdb/interface_influxdb.cpp
View File

@@ -71,6 +71,12 @@ void InfluxDBPublish(std::string _key, std::string _content, std::string _timest
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "InfluxDBPublish - Key: " + _key + ", Content: " + _content + ", Timestamp: " + _timestamp); LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "InfluxDBPublish - Key: " + _key + ", Content: " + _content + ", Timestamp: " + _timestamp);
// generate timestamp (TODO: parse result timestamp passed as string and convert it to POSIX timestamp?) // generate timestamp (TODO: parse result timestamp passed as string and convert it to POSIX timestamp?)
// Format: #define PREVALUE_TIME_FORMAT_OUTPUT "%Y-%m-%dT%H:%M:%S%z"
struct tm tm;
strptime(_timestamp.c_str(), "PREVALUE_TIME_FORMAT_OUTPUT", &tm);
time_t t = mktime(&tm); // t is now your desired time_t
// time_t now = time(NULL); // time_t now = time(NULL);
time_t now; time_t now;
time(&now); time(&now);
@@ -78,7 +84,10 @@ void InfluxDBPublish(std::string _key, std::string _content, std::string _timest
// pad with zeroes to get nanoseconds // pad with zeroes to get nanoseconds
sprintf(nowTimestamp,"%ld000000000", (long) now); sprintf(nowTimestamp,"%ld000000000", (long) now);
std::string payload = _influxDBMeasurement + " " + _key + "=" + _content + " " + nowTimestamp + "(time not used yet)";
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Test Time Conversion - now:" + std::to_string(now) + ", timestamp: " + std::to_string(t) + "(correct time not used yet)");
std::string payload = _influxDBMeasurement + " " + _key + "=" + _content + " " + nowTimestamp;
payload.shrink_to_fit(); payload.shrink_to_fit();
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "sending line to influxdb:" + payload); LogFile.WriteToFile(ESP_LOG_INFO, TAG, "sending line to influxdb:" + payload);