GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-26 03:40:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2415 from ZhouBox/main

Browse Source 
ekuiper:support precision
This commit is contained in:
fengzeroz
2025-03-19 16:00:18 +08:00
committed by GitHub
parent f4eff32cbf 66cd4da4d6
commit 6de92faa9b
1 changed files with 24 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/json_rw.c
+24 -2
View File
@@ -195,10 +195,21 @@ static int decode_write_req_json(void *json_obj, neu_json_write_req_t *req)
.name = "value",
.t = NEU_JSON_VALUE,
},
{
.name = "precision",
.t = NEU_JSON_INT,
.attribute = NEU_JSON_ATTRIBUTE_OPTIONAL,
},
};
ret = neu_json_decode_by_json(json_obj, NEU_JSON_ELEM_SIZE(req_elems),
ret = neu_json_decode_by_json(json_obj, NEU_JSON_ELEM_SIZE(req_elems),
req_elems);
req->node = req_elems[0].v.val_str;
if (req_elems[4].v.val_int > 0) {
req_elems[3].t = NEU_JSON_DOUBLE;
req_elems[3].v.val_double = (double_t) req_elems[3].v.val_int;
}
req->node = req_elems[0].v.val_str;
req->group = req_elems[1].v.val_str;
req->tag = req_elems[2].v.val_str;
req->t = req_elems[3].t;
@@ -259,10 +270,21 @@ static int decode_write_tags_req_json(void * json_obj,
.name = "value",
.t = NEU_JSON_VALUE,
},
{
.name = "precision",
.t = NEU_JSON_INT,
.attribute = NEU_JSON_ATTRIBUTE_OPTIONAL,
},
};
ret = neu_json_decode_array_by_json(
json_obj, "tags", i, NEU_JSON_ELEM_SIZE(v_elems), v_elems);
if (v_elems[2].v.val_int > 0) {
v_elems[1].t = NEU_JSON_DOUBLE;
v_elems[1].v.val_double = (double_t) v_elems[1].v.val_int;
}
req->tags[i].tag = v_elems[0].v.val_str;
req->tags[i].t = v_elems[1].t;
req->tags[i].value = v_elems[1].v;