說明
請注意替換例子中 your-bucket 為真實的 bucket。
1. 說明:
本例子將啟動一個作業(job),該作業包含一個任務(task), 該任務將啟動2個instance,并行在2個VM中運行。
2個VM中運行的程序是一樣的,都是任務sum中指定的命令”python sum.py”, 程序中使用環境變量中的 BATCH_COMPUTE_DAG_INSTANCE_ID 獲取InstanceId, 用來區分Input數據。
InstanceId是從0開始遞增的。
每個VM中任務程序處理完 ${InstanceId}-input.txt 數據后,將結果寫入到 /home/outputs/${InstanceId}-output.txt 文件, 系統會自動上傳到對應的OSS目錄:oss://your-bucket/sum/outputs/ 目錄下。
當2個VM中的程序都運行完成后,任務結束,作業結束。
例子可以在這里下載。
2. 上傳數據文件到OSS
數據文件在 data 目錄下: 0-input.txt和1-input.txt。
0-input.txt的內容:
1 20 45
1-input.txt的內容:
5 85 103
將 0-input.txt和1-input.txt 上傳到:
oss://your-bucket/sum/inputs/0-input.txt
oss://your-bucket/sum/inputs/1-input.txt
可以使用下面的命令上傳:
cd data
bcs oss upload 0-input.txt oss://your-bucket/sum/inputs/
bcs oss upload 1-input.txt oss://your-bucket/sum/inputs/
# 查看是否上傳成功
bcs oss ls oss://your-bucket/sum/inputs/
3. 啟動任務
bcs sub --file job.cfg
4. 查看結果
結果數據在 oss://your-bucket/sum/outputs/中。
可以用下面的命令查看:
bcs o ls oss://your-bucket/sum/outputs/
bcs o cat oss://your-bucket/sum/outputs/0-output.txt
bcs o cat oss://your-bucket/sum/outputs/1-output.txt
文檔內容是否對您有幫助?