redis消息json串格式修改，去掉parameters

L1/dockerfiles/redis-cli/run.sh

@@ -30,17 +30,18 @@ do
         fi
 
         # 提取dag_run_id
-        dag_run_id=$(echo "$msg" | jq -r '.parameters.dag_run_id')
+        dag_run_id=$(echo "$msg" | jq -r '.dag_run_id')
         echo "dag_run_id : "$dag_run_id
 
-        message=$(echo "$msg" | jq -c '.parameters.message')
+        message=$(echo "$msg" | jq -c '.message')
         
         # 提取message
-        echo "$message" >> "msgs.txt"
+        #echo "$message" >> "msgs.txt"
 
+        echo "$(date)    massgae :"$message >> "msgs.txt"
         #send-message $obsid
         job_name="message-router-csst"
-        scalebox task add --app-id ${app_id} --header dag_run_id=${dag_run_id} --upsert --sink-job ${job_name} ${message}
+        scalebox task add --app-id ${app_id} --header dag_run_id=${dag_run_id} --header repeatable=yes --upsert --sink-job ${job_name} ${message}
         code=$?
 
     fi