#!/bin/sh # # # # # # # # # # # # # # # # # # # # # # # @author : jiangfan # @date : 2020-11-24 15:00:51 # # # # # # # # # # # # # # # # # # # # # # source ../../dmp_env.sh LOG_TIME=$(date -d "$ScheduleTime" +"%Y-%m-%d") # fors=100 # concurrent=10000 # hour=00 # java -cp /root/workspace/DMP-1.0.3-jar-with-dependencies.jar mobvista.dmp.datasource.ali.AlipayRequestMain ${fors} ${concurrent} ${LOG_TIME} "IMEI_MD5" if [[ ! -d "/home/hadoop/jiangfan" ]]; then mkdir /home/hadoop/jiangfan cd /home/hadoop/jiangfan/ hdfs dfs -get s3://mob-emr-test/wangjf/data/pem/dataplatform_cn.pem . chmod 600 dataplatform_cn.pem fi fors=1550 concurrent=10000 device_type="IMEI_MD5" hour="03" #ssh -o "StrictHostKeyChecking no" -i /home/hadoop/jiangfan/dataplatform_cn.pem -l root 182.92.177.185 "/root/jiangfan/alipay_lahuo_laxin/exec_alipay_request.sh ${fors} ${concurrent} ${LOG_TIME} ${device_type} >/root/jiangfan/alipay_lahuo_laxin/exec_alipay_request.log" ssh -o "StrictHostKeyChecking no" -i /home/hadoop/jiangfan/dataplatform_cn.pem -l root 182.92.177.185 "/root/jiangfan/alipay_lahuo_laxin/exec_alipay_request.sh ${fors} ${concurrent} ${LOG_TIME} ${device_type} ${hour}" if [[ $? -ne 0 ]];then exit 255 fi echo "kill java process begin" sleep 200 shell=" -cp /root/jiangfan/alipay_lahuo_laxin/DMP-1.0.3-jar-with-dependencies.jar mobvista.dmp.datasource.ali.AlipayRequestMain ${fors} ${concurrent} ${LOG_TIME} ${device_type} ${hour}" ssh -o "StrictHostKeyChecking no" -i /home/hadoop/jiangfan/dataplatform_cn.pem -l root 182.92.177.185 "sh -x /root/jiangfan/alipay_lahuo_laxin/check_process.sh '${shell}'" if [[ $? -ne 0 ]];then exit 255 fi