Browse Source

添加历史数据导入

wdl 2 years ago
parent
commit
3fc5a818fc
1 changed files with 2 additions and 2 deletions
  1. 2 2
      energy/dayTask/bus_mysql_to_hdfs.sh

+ 2 - 2
energy/dayTask/bus_mysql_to_hdfs.sh

@@ -47,7 +47,7 @@ mysql_to_hdfs_lzo_no_partition() {
 	--connect "$1" \
 	--username "$2" \
 	--password "$3" \
-	--target-dir "$4""$7"/"$do_date" \
+	--target-dir "$4""$7" \
 	--delete-target-dir \
 	--columns "$5" \
 	--query "$6 and \$CONDITIONS" \
@@ -72,7 +72,7 @@ ods_feedback(){
 }
 
 ods_feedback_tmp(){
-  mysql_to_hdfs_lzo_no_partition "$url" "$username" "$password" /warehouse/saga_dw/ods/tmp/  \
+  mysql_to_hdfs_lzo_no_partition "$url" "$username" "$password" /warehouse/saga_dw/ods/  \
   "id, project_id, object_id, source_type, user_id, user_phone, user_name, value_type, item_id, value, create_time, next_open_time, model, duration_type, custom_plan, curr_temp, nick_name, result, exe_result, fb_temp, remark" \
   "select id, project_id, object_id, source_type, user_id, user_phone, user_name, value_type, item_id, value, create_time, next_open_time, model, duration_type, custom_plan, curr_temp, nick_name, result, exe_result, fb_temp, remark from feedback where 1 = 1 " \
   ods_bus_feedback_tmp