m_country_interest.sh 1.07 KB
Newer Older
wang-jinfeng committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39
#!/usr/bin/env bash

# # # # # # # # # # # # # # # # # # # # # #
# @file    :m_count_country_interest.sh
# @author  :liushuai
# @revision:2017-05-17 20:09
# @desc    :每天的m用户的兴趣标签
# # # # # # # # # # # # # # # # # # # # # #

source ../prd_env.sh

echo "ScheduleTime=$ScheduleTime"
LOG_TIME=$(date +%Y%m%d -d "-2 days $ScheduleTime")

date_path=${LOG_TIME:0:4}/${LOG_TIME:4:2}/${LOG_TIME:6:2}


INTEREST_INPUT_PATH="$DM_INTEREST_PATH/$date_path/all/"
M_INPUT_PATH="${REQUEST_TMP_PATH}/etl_adn_sdk_request_daily/${date_path}"
OUTPUT_PATH="${REQUEST_TMP_PATH}/tmp_m_interest/${date_path}"

#检查文件是否存在
check_await "$DM_INTEREST_PATH/$date_path/all/_SUCCESS"
check_await "${M_INPUT_PATH}/_SUCCESS"

REDUCE_NUM=$(calculate_reduce_num "${INTEREST_INPUT_PATH}")

hadoop fs -rm -r $OUTPUT_PATH

hadoop jar ../${JAR} mobvista.prd.datasource.country.interest.mapreduce.CountryInterestMR \
    -Dmapreduce.fileoutputcommitter.algorithm.version=2 \
    ${M_INPUT_PATH} \
    ${INTEREST_INPUT_PATH} \
    ${OUTPUT_PATH} \
    ${REDUCE_NUM}

if [ $? -ne 0 ]; then
    exit 255
fi