If your source file is not an HDFS file, upload it to COS via COS Console or API, and then analyze it in the EMR cluster.
-ak <ak> the cos secret id -appid,--appid <appid> the cos appid -bucket,--bucket <bucket_name> the cos bucket name -cos_info_file,--cos_info_file <arg> the cos user info config default is ./conf/cos_info.conf -cos_path,--cos_path <cos_path> the absolute cos folder path -h,--help print help message -hdfs_conf_file,--hdfs_conf_file <arg> the hdfs info config default is ./conf/core-site.xml -hdfs_path,--hdfs_path <hdfs_path> the hdfs path -region,--region <region> the cos region. legal value cn-south, cn-east, cn-north, sg -sk <sk> the cos secret key -skip_if_len_match,--skip_if_len_match skip upload if hadoop file length match cos
All operations must be performed in the tool directory. If both configuration files and command line parameters are set, the latter will prevail ./hdfs_to_cos_cmd -h Copy from HDFS to COS (if a file already exists in COS, it will be overwritten) ./hdfs_to_cos_cmd --hdfs_path=/tmp/hive --cos_path=/hdfs/20170224/ Copy from HDFS to COS, and if a file to be copied is of the same length as a file in COS, then it is skipped (this is suitable for repeated copy) Only the length is checked here, as the overheads would be very high if the digests of files in Hadoop are to be calculated ./hdfs_to_cos_cmd --hdfs_path=/tmp/hive --cos_path=/hdfs/20170224/ -skip_if_len_match Set parameters completely through the command line ./hdfs_to_cos_cmd -appid 1252xxxxxx -ak AKIDVt55xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx -sk KS08jDVbVElxxxxxxxxxxxxxxxxxxxxxxxxxx -bucket test -cos_path /hdfs -hdfs_path /data/data -region cn-south -hdfs_conf_file /home/hadoop/hadoop-2.8.1/etc/hadoop/core-site.xml
[Folder Operation Result : [ 53(sum)/ 53(ok) / 0(fail)] [File Operation Result: [22(sum)/ 22(ok) / 0(fail) / 0(skip)] [Used Time: 3 s]
sumindicates the total number of files to be migrated.
okindicates the number of files successfully migrated.
failindicates the number of files failed to be migrated.
skipindicates the number of files skipped because they have the same length as the files of the same name in the destination after the
skip_if_len_matchparameter is added.
You can also log in to the COS Console to see whether the data has been migrated correctly.