读写消息

Author: suyh

tmp-flink-queue/v1.1.0/push_multi_task.sh

@@ -0,0 +1,12 @@
+#!/bin/bash
+
+
+DATES_BEGIN=2024-11-01
+for ((offset = 0; offset < 42; offset++)); do
+  DATES=$(date -d "${DATES_BEGIN} +$offset days" +%Y%m%d)
+  echo "DATES: ${DATES}"
+  ./ipcmqs -w --pns inr,cny --date ${DATES} --jobName cohort_batch
+  ./ipcmqs -w --pns inr,cny --date ${DATES} --jobName realtime_batch
+  ./ipcmqs -w --pns inr,cny --date ${DATES} --jobName repetition_batch
+done
+