GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-18 13:41:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'v2.13' of github.com:ZhouBox/neuron into v2.13

Browse Source
This commit is contained in:
xiang.zhou
2025-10-31 10:17:40 +08:00
parent 3828658405 83828e0ea5
commit 8225ba0703
1 changed files with 12 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/restful/normal_handle.c
+12 -14
View File
@@ -722,7 +722,7 @@ int tags_write_to_csv(const char *filename, const char *node_name,
int write_csv_header()
{
FILE *f = fopen("/tmp/nodes.csv", "w");
FILE *f = fopen("nodes.csv", "w");
if (NULL == f) {
nlog_error("failed to open file:%s", "nodes.csv");
return -1;
@@ -730,7 +730,7 @@ int write_csv_header()
fprintf(f, "name,type,state,plugin_name\n");
fclose(f);
f = fopen("/tmp/settings.csv", "w");
f = fopen("settings.csv", "w");
if (NULL == f) {
nlog_error("failed to open file:%s", "settings.csv");
return -1;
@@ -738,7 +738,7 @@ int write_csv_header()
fprintf(f, "node_name,setting\n");
fclose(f);
f = fopen("/tmp/groups.csv", "w");
f = fopen("groups.csv", "w");
if (NULL == f) {
nlog_error("failed to open file:%s", "groups.csv");
return -1;
@@ -746,7 +746,7 @@ int write_csv_header()
fprintf(f, "driver_name,name,interval,context\n");
fclose(f);
f = fopen("/tmp/tags.csv", "w");
f = fopen("tags.csv", "w");
if (NULL == f) {
nlog_error("failed to open file:%s", "tags.csv");
return -1;
@@ -756,7 +756,7 @@ int write_csv_header()
"decimal,bias,type,description,format,value\n");
fclose(f);
f = fopen("/tmp/subscribes.csv", "w");
f = fopen("subscribes.csv", "w");
if (NULL == f) {
nlog_error("failed to open file:%s", "subscribes.csv");
return -1;
@@ -820,7 +820,7 @@ void handle_export_db(nng_aio *aio)
return;
}
rv = nodes_write_to_csv("/tmp/nodes.csv", nodes);
rv = nodes_write_to_csv("nodes.csv", nodes);
if (rv != 0) {
NEU_JSON_RESPONSE_ERROR(NEU_ERR_FILE_WRITE_FAILURE, {
neu_http_response(aio, error_code.error, result_error);
@@ -837,7 +837,7 @@ void handle_export_db(nng_aio *aio)
if (rv != 0) {
continue;
}
rv = settings_write_to_csv("/tmp/settings.csv", node->name, settings);
rv = settings_write_to_csv("settings.csv", node->name, settings);
free(settings);
if (rv != 0) {
NEU_JSON_RESPONSE_ERROR(NEU_ERR_FILE_WRITE_FAILURE, {
@@ -856,7 +856,7 @@ void handle_export_db(nng_aio *aio)
if (rv != 0) {
continue;
}
rv = subscribes_write_to_csv("/tmp/subscribes.csv", node->name,
rv = subscribes_write_to_csv("subscribes.csv", node->name,
subscribers);
utarray_free(subscribers);
if (rv != 0) {
@@ -876,7 +876,7 @@ void handle_export_db(nng_aio *aio)
if (rv != 0) {
continue;
}
rv = groups_write_to_csv("/tmp/groups.csv", node->name, groups);
rv = groups_write_to_csv("groups.csv", node->name, groups);
if (rv != 0) {
NEU_JSON_RESPONSE_ERROR(NEU_ERR_FILE_WRITE_FAILURE, {
neu_http_response(aio, error_code.error, result_error);
@@ -892,8 +892,7 @@ void handle_export_db(nng_aio *aio)
if (rv != 0) {
continue;
}
rv = tags_write_to_csv("/tmp/tags.csv", node->name, group->name,
tags);
rv = tags_write_to_csv("tags.csv", node->name, group->name, tags);
if (rv != 0) {
NEU_JSON_RESPONSE_ERROR(NEU_ERR_FILE_WRITE_FAILURE, {
neu_http_response(aio, error_code.error, result_error);
@@ -910,9 +909,8 @@ void handle_export_db(nng_aio *aio)
utarray_free(nodes);
system("rm -rf /tmp/neuron.zip");
system("zip /tmp/neuron.zip /tmp/nodes.csv /tmp/settings.csv "
"/tmp/groups.csv /tmp/tags.csv "
"/tmp/subscribes.csv");
system("zip /tmp/neuron.zip nodes.csv settings.csv groups.csv tags.csv "
"subscribes.csv");
void * data = NULL;
size_t len = 0;