Блог

У меня есть приложение nodejs, в котором я прослушиваю изменения базы данных в реальном времени с помощью событий MySQL, и по какой-то причине оно перестает читать журналы и получать изменения… Я использовал socket io для передачи изменений в реальном времени.

    const watcher = async () => {

 
   var instance = new MySQLEvents(connection, {
     startAtEnd: true,
     serverId: 1,
     
 
   })
   await instance.start()  .then(() =>  log4j.loggerinfo.info(`i'm running`))
   .catch(err => log4j.loggerinfo.error(`${err.message}`))
 
   instance.addTrigger({
     name: 'balance update',
     expression: 'afff.users.balance',
     statement: MySQLEvents.STATEMENTS.UPDATES,
     onEvent: async(event) => { // You will receive the events here
      instance.pause()
       await doSomethingOnBalanceChange(event)
      instance.resume()

      //  io.of('/').emit('operationReceived', event)
 
     },
   })