11.update.mql 2.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. select id,identifier,agent,node,severity,msg,lastoccurrence,vtime,tally from /test/malert_status
  2. where identifier=?
  3. refresh
  4. -- { output() params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  5. ;
  6. insert into /test/malert_status (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
  7. -- { params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999", 5, 1622249715000, 1, "设备:(222.129.134.178\u0029电源整体功能恢复! 00000000999999999", 2, "huawei mttrapd #0000999", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:(222.129.134.178\u0029电源整体功能恢复! 000000009999") }
  8. ;
  9. -- insert 可能存在延迟写入,因此判断实际库存值前需要等待
  10. -- { sleep(1s) }
  11. ;
  12. select id,identifier,agent,node,severity,msg,lastoccurrence,vtime,tally from /test/malert_status
  13. where identifier=?
  14. refresh
  15. -- { output() equal(0,severity,5) params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  16. ;
  17. update /test/malert_status
  18. set severity=4,
  19. msg='设备:(222.129.134.178\u0029电源整体功能恢复! 9999999999999'
  20. where id='7663188898751057475'
  21. ;
  22. select id,identifier,agent,node,severity,msg,lastoccurrence,vtime,tally from /test/malert_status
  23. where identifier=?
  24. refresh
  25. -- { output() equal(0,severity,4) params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  26. ;
  27. update /test/malert_status
  28. set severity=3,
  29. msg='设备:(222.129.134.178\u0029电源整体功能恢复! 9999999999999'
  30. where id=?
  31. -- { parallel(1) loop(1) params("7663188898751057475") }
  32. ;
  33. select identifier,agent,node,severity,msg,lastoccurrence,vtime,tally from /test/malert_status
  34. where identifier=?
  35. refresh
  36. -- { output() equal(0,severity,3) params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  37. ;
  38. update /test/malert_status
  39. set severity=2,
  40. msg='设备:(222.129.134.178\u0029电源整体功能恢复! 9999999999999'
  41. where identifier=?
  42. -- { parallel(1) loop(1) params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  43. ;
  44. select identifier,agent,node,severity,msg,lastoccurrence,vtime,tally from /test/malert_status
  45. where identifier=?
  46. refresh
  47. -- { output() equal(0,severity,2) params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.600009999") }
  48. ;