Influxdb не может иногда сохранять данные - PullRequest
Новая
       39

Influxdb не может иногда сохранять данные

0 голосов
/ 28 января 2020

Я использую Influxdb для сохранения своих данных, каждую секунду я отправляю данные по NodeJS через curl. Иногда Influxdb не может сохранять данные, а Графана не показывает данные.
Это один из моих кудрей: 

curl -i -XPOST 'http://localhost:8086/write?db=hajitsu' --data-binary 'dispatcher value=0.15240792448141582,incoming_buffer_current_size=68,outgoing_buffer_current_size=59,thread_issuer_outgoing=46,thread_issuer_incoming=48,buffer_issuer_out=32,buffer_issuer_in=14,thread_acquire_outgoing=51,thread_acquire_incoming=55,buffer_acquire_out=77,buffer_acquire_in=10,thread_reversal_outgoing=44,thread_reversal_incoming=95,buffer_reversal_out=84,buffer_reversal_in=36,thread_pilot_outgoing=30,thread_pilot_incoming=72,buffer_pilot_out=92,buffer_pilot_in=16 1580157002729000000'


А это диаграмма мониторинга Grafana .: Grafana chart


Как я могу решить эту проблему? Это мой пример NodeJS данные прокачки: 

 var dt = new Date();
var nowDt = timestamp.fromDate(dt).toString();
var now_time = `${timestamp.fromString(nowDt).getTimeT()}${ timestamp.fromString(nowDt).getNano()}`;
var command_dispatcher = `curl -i -XPOST 'http://localhost:8086/write?db=hajitsu' --data-binary 'dispatcher value=${Math.random()},incoming_buffer_current_size=${randomIntInc()},outgoing_buffer_current_size=${randomIntInc()},thread_issuer_outgoing=${randomIntInc()},thread_issuer_incoming=${randomIntInc()},buffer_issuer_out=${randomIntInc()},buffer_issuer_in=${randomIntInc()},thread_acquire_outgoing=${randomIntInc()},thread_acquire_incoming=${randomIntInc()},buffer_acquire_out=${randomIntInc()},buffer_acquire_in=${randomIntInc()},thread_reversal_outgoing=${randomIntInc()},thread_reversal_incoming=${randomIntInc()},buffer_reversal_out=${randomIntInc()},buffer_reversal_in=${randomIntInc()},thread_pilot_outgoing=${randomIntInc()},thread_pilot_incoming=${randomIntInc()},buffer_pilot_out=${randomIntInc()},buffer_pilot_in=${randomIntInc()} ${now_time}'`
log( now_time, nowDt, command_dispatcher);

exec(command_dispatcher, function(error, stdout, stderr){
    if(error !== null)
    {
        console.log('exec error: ' + error);
    }
});


В вышеприведенном коде я просто закачиваю данные образца в файл effxdb.
И это мой журнал, в который я отправлял данные, в какое время для притока по curl: 

1580157002729000000 -- 2020-01-27T20:30:02.729000000Z => curl -i -XPOST 'http://localhost:8086/write?db=hajitsu' --data-binary 'shetab_dispatcher value=0.15240792448141582,shetab_incoming_buffer_current_size=68,shetab_outgoing_buffer_current_size=59,thread_issuer_outgoing=46,thread_issuer_incoming=48,buffer_issuer_out=32,buffer_issuer_in=14,thread_acquire_outgoing=51,thread_acquire_incoming=55,buffer_acquire_out=77,buffer_acquire_in=10,thread_reversal_outgoing=44,thread_reversal_incoming=95,buffer_reversal_out=84,buffer_reversal_in=36,thread_pilot_outgoing=30,thread_pilot_incoming=72,buffer_pilot_out=92,buffer_pilot_in=16 1580157002729000000'
...