Работа с Websockets и Kue.js - PullRequest
Новая
       28

Работа с Websockets и Kue.js

0 голосов
/ 23 октября 2018

Я немного озадачен тем, как логически работает моя установка.

У меня есть соединение через веб-сокет по паритету EUR / USD.Я получаю данные каждую секунду из этого веб-сокета.

Данные таковы: 

{"DATE":"2016-07-01 00:05:00","OPEN":"1.11024","HIGH":"1.11037","LOW":"1.11016","CLOSE":"1.11037","VOLUME":"13"}

И я сохраняю этот объект в библиотеке Nodejs kue.js как 

const parityQueue = kue.createQueue({
prefix: 'parity',
redis: {
    port: 6379,
    host: 'hostname',
    auth: 'AUTH',
    db: 1
}
})

Я добавляю данные в очередь, например 

let data = {
            date: mDate,
            last_value:last_value,
            sales_value: last_value + profitBuy,
            buy:true
        }

        parityQueue.create('parityBuy',data).save(err => {
            if(err)
                console.log(err)
        })

sales_value - это число, которое я буду покупать, когда паритет получит это значение, но значение исходит из websocket.

когда это значениеOPEN приходит к моему sales_value. Я хочу что-то сделать 

{"DATE":"2016-07-01 00:05:00","OPEN":"1.11024","HIGH":"1.11037","LOW":"1.11016","CLOSE":"1.11037","VOLUME":"13"}

Пока я обрабатываю работу, я хочу сделать это 

parityQueue.process('paritySell',(res,done) => {

  let data = OPEN property of websocket data but this data is coming from websocket. Real-Time

if(data >= res.data.OPEN)
   add to database


})
...