xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[TD-6443]<feature>: Support OpenTSDB HTTP JSON data import format

This commit is contained in:
Ganlin Zhao 2021-09-06 12:32:49 +08:00
parent 997a119c65
commit 80bb505a23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/client/src/tscParseOpenTSDB.c
View File

@ -13,7 +13,7 @@
#include "tscParseLine.h" #include "tscParseLine.h"
#define MAX_FILEDS_NUM 2 #define MAX_FIELDS_NUM 2
#define JSON_FIELDS_NUM 4 #define JSON_FIELDS_NUM 4
#define OTS_TIMESTAMP_COLUMN_NAME "ts" #define OTS_TIMESTAMP_COLUMN_NAME "ts"
@ -85,7 +85,7 @@ static int32_t parseTelnetTimeStamp(TAOS_SML_KV **pTS, int *num_kvs, const char
start = cur = *index; start = cur = *index;
//allocate fields for timestamp and value //allocate fields for timestamp and value
*pTS = tcalloc(MAX_FILEDS_NUM, sizeof(TAOS_SML_KV)); *pTS = tcalloc(MAX_FIELDS_NUM, sizeof(TAOS_SML_KV));
while(*cur != '\0') { while(*cur != '\0') {
if (*cur == ' ') { if (*cur == ' ') {
@ -451,7 +451,7 @@ int32_t parseMetricFromJSON(cJSON *root, TAOS_SML_DATA_POINT* pSml, SSmlLinesInf
return TSDB_CODE_TSC_INVALID_JSON; return TSDB_CODE_TSC_INVALID_JSON;
} }
tstrncpy(pSml->stableName, metric->valuestring, stableLen); tstrncpy(pSml->stableName, metric->valuestring, stableLen + 1);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
@ -470,7 +470,7 @@ int32_t parseTimestampFromJSON(cJSON *root, TAOS_SML_KV **pTS, int *num_kvs, SSm
} }
//allocate fields for timestamp and value //allocate fields for timestamp and value
*pTS = tcalloc(MAX_FILEDS_NUM, sizeof(TAOS_SML_KV)); *pTS = tcalloc(MAX_FIELDS_NUM, sizeof(TAOS_SML_KV));
tsVal = convertTimePrecision(timestamp->valueint, TSDB_TIME_PRECISION_MICRO, TSDB_TIME_PRECISION_NANO); tsVal = convertTimePrecision(timestamp->valueint, TSDB_TIME_PRECISION_MICRO, TSDB_TIME_PRECISION_NANO);