dump_stream_config_failed_queue.sh

dump_stream_config_failed_queue.sh

export PORT=9001
export FILE_NAME=new_dump.txt

function get_redis_data() {
  KEY_NAME=$1
  configID=$(echo HGET $KEY_NAME data | redis-cli -p $PORT | jq '.streamConfigurationId')
  configFailedReason=$(echo "HGET $KEY_NAME failedReason" | redis-cli -p $PORT)

  echo "===================" >> $FILE_NAME
  echo "configId: $configID\nFailedReason:$configFailedReason" >> $FILE_NAME
}

KEYS_TO_INSPECT=(KEYS_TO_INSPECT=$(echo "KEYS bull:stream_configurations:*" | redis-cli -p 9001 | awk '{print $1}' | tr '\n' "' '"))
for key in "${KEYS_TO_INSPECT[@]}"
do
  echo $key
  get_redis_data $key
done

echo "done"