2230datasync.mql 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152
  1. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise',
  2. [{ '__name__':'key1', '__value__':2, '__timestamp__':'2024-07-27 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  3. { '__name__':'key2', '__value__':8.81, '__timestamp__':'2024-07-27 11:25:18', 'disk':'/opt/matrix/test', 'CPU':'CPU2'},
  4. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-27 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  5. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-27 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'},
  6. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-28 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  7. { '__name__':'key2', '__value__':8.82, '__timestamp__':'2024-07-28 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  8. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-28 11:25:19', 'disk':'/opt/matrix/test', 'CPU':'CPU5'},
  9. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-28 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'},
  10. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-29 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  11. { '__name__':'key2', '__value__':8.83, '__timestamp__':'2024-07-29 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  12. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-29 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  13. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-29 11:26:19', 'disk':'/opt/matrix/test', 'CPU':'CPU48'},
  14. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-30 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  15. { '__name__':'key2', '__value__':8.84, '__timestamp__':'2024-07-30 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  16. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-30 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  17. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-30 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'}] )
  18. ;
  19. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:24:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:24:00.000';
  20. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2, '__timestamp__':'2024-11-28 11:25:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:25:00.001';
  21. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:26:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:26:00.002';
  22. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:27:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:27:00.003';
  23. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:28:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:28:00.004';
  24. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:29:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:29:00.005';
  25. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:30:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:30:00.006';
  26. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:31:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:31:00.007';
  27. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:32:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:32:00.008';
  28. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:24:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:24:00.009';
  29. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:25:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:25:00.010';
  30. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:26:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:26:00.011';
  31. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:27:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:27:00.012';
  32. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:28:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:28:00.013';
  33. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:29:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:29:00.014';
  34. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:30:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:30:00.015';
  35. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:31:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:31:00.016';
  36. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:32:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:32:00.017';
  37. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11',
  38. [{ '__name__':'key1', '__value__':2, '__timestamp__':'2024-07-27 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  39. { '__name__':'key2', '__value__':8.81, '__timestamp__':'2024-07-27 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  40. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-27 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  41. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-27 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'},
  42. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-28 11:24:17', 'disk':'/opt/matrix/test', 'CPU':'CPU1'},
  43. { '__name__':'key2', '__value__':8.82, '__timestamp__':'2024-07-28 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  44. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-28 11:25:19', 'disk':'/opt/matrix/test', 'CPU':'CPU5'},
  45. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-28 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'},
  46. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-29 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  47. { '__name__':'key2', '__value__':8.83, '__timestamp__':'2024-07-29 11:25:18', 'disk':'/opt/matrix/test', 'CPU':'CPU2'},
  48. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-29 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  49. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-29 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'},
  50. { '__name__':'key1', '__value__':2.7, '__timestamp__':'2024-07-30 11:24:17', 'disk':'/opt/matrix', 'CPU':'CPU1'},
  51. { '__name__':'key2', '__value__':8.84, '__timestamp__':'2024-07-30 11:25:18', 'disk':'/opt/matrix', 'CPU':'CPU2'},
  52. { '__name__':'key5', '__value__':2.9, '__timestamp__':'2024-07-30 11:25:19', 'disk':'/opt/matrix', 'CPU':'CPU5'},
  53. { '__name__':'key48', '__value__':2.9, '__timestamp__':'2024-07-30 11:26:19', 'disk':'/opt/matrix', 'CPU':'CPU48'}] )
  54. ;
  55. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2, '__timestamp__':'2024-11-28 11:24:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:24:00.000';
  56. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:25:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:25:00.001';
  57. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:26:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:26:00.002';
  58. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:27:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:27:00.003';
  59. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:28:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:28:00.004';
  60. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:29:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:29:00.005';
  61. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:30:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:30:00.006';
  62. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:31:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:31:00.007';
  63. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key3', '__value__':2.7, '__timestamp__':'2024-11-28 11:32:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:32:00.008';
  64. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:24:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:24:00.009';
  65. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:25:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:25:00.010';
  66. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:26:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:26:00.011';
  67. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:27:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:27:00.012';
  68. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:28:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:28:00.013';
  69. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:29:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:29:00.014';
  70. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:30:00', 'disk':'/opt/matrix/test', 'CPU':'CPU1'}] ) at '2024-11-28 11:30:00.015';
  71. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:31:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:31:00.016';
  72. insert into /test/bucketpromdbsync (id, prom_sync) values ('bucketpromdbsync:wecise11', [{ '__name__':'key1.key2.key4', '__value__':2.7, '__timestamp__':'2024-11-28 11:32:00', 'disk':'/opt/matrix', 'CPU':'CPU1'}] ) at '2024-11-28 11:32:00.017';
  73. insert into /test/bucketpromdbsync (id, prom_sync) values (?, ? )
  74. /**
  75. beforerun(
  76. set(ct,"2024-07-28 11:24:17"),
  77. add(ct,mqli,second)
  78. )
  79. loop(1000)
  80. params("bucketpromdbsync:wecise", [
  81. {"name": "key1{%d,mqli}", "value": 2, "timestamp": "{%t,ct}"},
  82. {"name": "key_{%d,mqli}", "value": 1.8, "timestamp": "{%t,ct}"},
  83. {"name": "key_3_{%d,mqli}", "value": 2.9, "timestamp": "{%t,ct}"},
  84. {"name": "keys{%d,mqli}", "value": "sss", "timestamp": "{%t,ct}"},
  85. {"name": "keys2_{%d,mqli}", "value": "这是中文长字符串sssss", "timestamp": "{%t,ct}"},
  86. {"name": "key48_{%d,mqli}", "value": 2.9, "timestamp": "{%t,ct}"}])
  87. **/
  88. ;
  89. insert into /test/bucketpromdbsync (id, prom_sync) values (?, ? )
  90. /**
  91. params("bucketpromdbsync:wecise", [
  92. {"name": "key1", "value": 2, "timestamp": "2024-07-28 12:24:17"},
  93. {"name": "key2", "value": 1.9, "timestamp": "2024-07-28 12:25:18"},
  94. {"name": "key3", "value": 3.9, "timestamp": "2024-07-28 12:25:19"},
  95. {"name": "keys1", "value": "ssss", "timestamp": "2024-07-28 12:25:19"},
  96. {"name": "keys2", "value": "ss这是中文长字符串sssss", "timestamp": "2024-07-28 12:25:19"},
  97. {"name": "key48", "value": 3.9, "timestamp": "2024-07-28 12:25:19"}])
  98. **/
  99. ;
  100. insert into /test/bucketpromdbsync (id, prom_sync) values (?, ? )
  101. /**
  102. params("bucketpromdbsync:wecise", [
  103. {"name": "key1", "value": 2.9, "timestamp": "2024-07-29 11:24:17", "disk": "/opt/matrix", "CPU": "CPU1"},
  104. {"name": "key2", "value": 2, "timestamp": "2024-07-29 11:25:18", "disk": "/opt/matrix", "CPU": "CPU2"},
  105. {"name": "key3", "value": 2.9, "timestamp": "2024-07-29 11:25:19", "disk": "/opt/matrix/test", "CPU": "CPU3"},
  106. {"name": "keys1", "value": "sss", "timestamp": "2024-07-29 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  107. {"name": "keys2", "value": "这是中文长字符串sssss", "timestamp": "2024-07-29 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  108. {"name": "key48", "value": 4, "timestamp": "2024-07-29 11:25:19", "disk": "/opt/matrix", "CPU": "CPU48"}])
  109. **/
  110. ;
  111. insert into /test/bucketpromdbsync (id, prom_sync) values (?, ? )
  112. /**
  113. params("bucketpromdbsync:wecise", [
  114. {"__name__": "key1", "__value__": 5.2, "__timestamp__": "2024-07-30 11:24:17", "disk": "/opt/matrix", "CPU": "CPU1"},
  115. {"__name__": "key2", "__value__": 4.8, "__timestamp__": "2024-07-30 11:25:18", "disk": "/opt/matrix", "CPU": "CPU2"},
  116. {"__name__": "key3", "__value__": 2, "__timestamp__": "2024-07-30 11:25:19", "disk": "/opt/matrix/test", "CPU": "CPU3"},
  117. {"__name__": "keys1", "__value__": "sss", "__timestamp__": "2024-07-30 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  118. {"__name__": "keys2", "__value__": "这是中文长字符串sssss", "__timestamp__": "2024-07-30 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  119. {"__name__": "key48", "__value__": 2.9, "__timestamp__": "2024-07-30 11:25:19", "disk": "/opt/matrix", "CPU": "CPU48"}])
  120. **/
  121. ;
  122. insert into /test/bucketpromdbsync (id, prom_sync) values (?, ? ) at ?
  123. /**
  124. params("bucketpromdbsync:wecise", [
  125. {"__name__": "key1", "__value__": 6.0, "__timestamp__": "2024-07-31 11:24:17", "disk": "/opt/matrix", "CPU": "CPU1"},
  126. {"__name__": "key2", "__value__": 3.8, "__timestamp__": "2024-07-31 11:25:18", "disk": "/opt/matrix", "CPU": "CPU2"},
  127. {"__name__": "key3", "__value__": 2.9, "__timestamp__": "2024-07-31 11:25:19", "disk": "/opt/matrix/test", "CPU": "CPU3"},
  128. {"__name__": "keys1", "__value__": "sss", "__timestamp__": "2024-07-31 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  129. {"__name__": "keys2", "__value__": "这是中文长字符串sssss", "__timestamp__": "2024-07-31 11:25:19", "disk": "/opt/matrix", "CPU": "CPU3"},
  130. {"__name__": "key48", "__value__": 2.9, "__timestamp__": "2024-07-31 11:25:19", "disk": "/opt/matrix/test", "CPU": "CPU48"}], "2024-07-31 11:24:17")
  131. **/
  132. ;
  133. /**
  134. sleep(1s)
  135. **/
  136. ;