AI 助理
备案控制台
官方文档
输入文档关键字查找
首页 批量计算（文档停止维护） 操作指南 App 参考示例

参考示例

更新时间：
我的收藏

下面使用 Python SDK 的方式，创建一个 App，作用是拷贝一个输入路径 inputparam1 的内容到一个输出路径 output，并打印自定义的环境变量，App 相关定义如下：

  • 输入信息
    • inputparam1：自定义输入参数1，OSS 路径，映射到本地的 /home/input/ 目录。
    • inputparam2：自定义输入参数2，非 OSS 路径，这里无具体含义，用于演示输入参数用法。
  • 输出信息
    • outout：自定义输出参数，OSS 路径，映射到本地的 /home/output/ 目录。
  • 环境变量：
    • env1：自定义环境变量，这里无具体含义，用于演示环境变量用法。

使用 Python SDK 创建基于 VM 镜像的 App

  1. #encoding=utf-8
  2. import sys
  3. from batchcompute import Client, ClientError
  4. from batchcompute import CN_BEIJING as REGION
  5. from batchcompute.resources import (
  6.     JobDescription, TaskDescription, DAG, AutoCluster, GroupDescription, ClusterDescription, AppDescription
  7. )
  8. ACCESS_KEY_ID='xxxx' # 填写您的 ACCESS_KEY_ID
  9. ACCESS_KEY_SECRET='xxxx' # 填写您的 ACCESS_KEY_SECRET
  11. def main():
  12.     try:
  13.         client = Client(REGION, ACCESS_KEY_ID, ACCESS_KEY_SECRET)
  15.         app_desc = {
  16.         "Name":"DemoApp_vm",
  17.         "Daemonize":False,
  18.         "VM":{
  19.             "ECSImageId":"img-ubuntu-vpc",
  20.         },
  21.         "CommandLine":"/bin/bash -c 'cp -r ${inputparam1} ${output} && echo ${inputparam2} && echo $env1'",
  22.         "InputParameters":{
  23.         "inputparam1":{
  24.             "Description":"",
  25.             "Type":"String",
  26.             "Default":"",
  27.             "LocalPath":"/home/input/"
  28.         },
  29.         "inputparam2":{
  30.             "Description":"",
  31.             "Type":"String",
  32.             "Default":"",
  33.             "LocalPath":""
  34.         }
  35.         },
  36.         "OutputParameters":{
  37.         "output":{
  38.             "Description":"",
  39.             "Type":"String",
  40.             "LocalPath":"/home/output/"
  41.         }
  42.         },
  43.         "Config":{
  44.         "ResourceType":{
  45.             "Default":"OnDemand",
  46.             "Overwritable":True
  47.         },
  48.         "InstanceType":{
  49.             "Description":"",
  50.             "Default":"ecs.c5.large",
  51.             "Overwritable":True
  52.         },
  53.         "InstanceCount":{
  54.             "Description":"",
  55.             "Default":1,
  56.             "Overwritable":True
  57.         },
  58.         "MinDiskSize":{
  59.             "Description":"",
  60.             "Default":40,
  61.             "Overwritable":True
  62.         },
  63.         "DiskType":{
  64.             "Description":"",
  65.             "Default":"cloud_efficiency",
  66.             "Overwritable":True
  67.         },
  68.         "MaxRetryCount":{
  69.             "Description":"",
  70.             "Default":0,
  71.             "Overwritable":True
  72.         },
  73.         "Timeout":{
  74.             "Description":"",
  75.             "Default":86400,
  76.             "Overwritable":True
  77.         }
  78.         },
  79.         "EnvVars":{
  80.             "env1":"abcd"
  81.         }   
  82.         }
  84.         appName = client.create_app(app_desc).Name
  85.         print('App created: %s' % appName)
  86.     except ClientError, e:
  87.         print (e.get_status_code(), e.get_code(), e.get_requestid(), e.get_msg())
  88. if __name__ == '__main__':
  89.     sys.exit(main())

使用 Python SDK 创建基于 Docker 镜像的 App

  1. #encoding=utf-8
  2. import sys
  3. from batchcompute import Client, ClientError
  4. from batchcompute import CN_BEIJING as REGION
  5. from batchcompute.resources import (
  6.     JobDescription, TaskDescription, DAG, AutoCluster, GroupDescription, ClusterDescription, AppDescription
  7. )
  8. ACCESS_KEY_ID='xxxx' # 填写您的 ACCESS_KEY_SECRET
  9. ACCESS_KEY_SECRET='xxxxxx' # 填写您的 ACCESS_KEY_SECRET
  11. def main():
  12.     try:
  13.         client = Client(REGION, ACCESS_KEY_ID, ACCESS_KEY_SECRET)
  15.         app_desc = {
  16.         "Name":"DemoApp_Docker",
  17.         "Daemonize":False,
  18.         "Docker":{
  19.             "Image":"localhost:5000/dockerimagename",
  20.             "RegistryOSSPath":"oss://bucket-name/dockers/"
  21.         },
  22.         "CommandLine":"/bin/bash -c 'cp -r ${inputparam1} ${output} && echo ${inputparam2} && echo $env1'",
  23.         "InputParameters":{
  24.         "inputparam1":{
  25.             "Description":"",
  26.             "Type":"String",
  27.             "Default":"",
  28.             "LocalPath":"/home/input/"
  29.         },
  30.         "inputparam2":{
  31.             "Description":"",
  32.             "Type":"String",
  33.             "Default":"",
  34.             "LocalPath":""
  35.         }
  36.         },
  37.         "OutputParameters":{
  38.         "output":{
  39.             "Description":"",
  40.             "Type":"String",
  41.             "LocalPath":"/home/output/"
  42.         }
  43.         },
  44.         "Config":{
  45.         "ResourceType":{
  46.             "Default":"OnDemand",
  47.             "Overwritable":True
  48.         },
  49.         "InstanceType":{
  50.             "Description":"",
  51.             "Default":"ecs.c5.large",
  52.             "Overwritable":True
  53.         },
  54.         "InstanceCount":{
  55.             "Description":"",
  56.             "Default":1,
  57.             "Overwritable":True
  58.         },
  59.         "MinDiskSize":{
  60.             "Description":"",
  61.             "Default":40,
  62.             "Overwritable":True
  63.         },
  64.         "DiskType":{
  65.             "Description":"",
  66.             "Default":"cloud_efficiency",
  67.             "Overwritable":True
  68.         },
  69.         "MaxRetryCount":{
  70.             "Description":"",
  71.             "Default":0,
  72.             "Overwritable":True
  73.         },
  74.         "Timeout":{
  75.             "Description":"",
  76.             "Default":86400,
  77.             "Overwritable":True
  78.         }
  79.         },
  80.         "EnvVars":{
  81.             "env1":"abcd"
  82.         }   
  83.         }
  85.         appName = client.create_app(app_desc).Name
  86.         print('App created: %s' % appName)
  87.     except ClientError, e:
  88.         print (e.get_status_code(), e.get_code(), e.get_requestid(), e.get_msg())
  89. if __name__ == '__main__':
  90.     sys.exit(main())

使用 Python SDK 提交 App 作业

  1. #encoding=utf-8
  2. import sys
  3. from batchcompute import Client, ClientError
  4. from batchcompute import CN_BEIJING as REGION
  5. from batchcompute.resources import (
  6.     JobDescription, TaskDescription, DAG, AutoCluster, GroupDescription, ClusterDescription, AppDescription, AppJobDescription
  7. )
  8. ACCESS_KEY_ID='xxxx' # 填写您的 ACCESS_KEY_ID
  9. ACCESS_KEY_SECRET='xxxx' # 填写您的 ACCESS_KEY_SECRET
  10. LOG_PATH = 'oss://bucket-name/bc_test/log/' 
  11. ERR_PATH = 'oss://bucket-name/bc_test/error/'
  13. def main():
  14.     try:
  15.         client = Client(REGION, ACCESS_KEY_ID, ACCESS_KEY_SECRET)
  16.         job_desc = AppJobDescription()
  18.         # Create job description.
  19.         job_desc.Name = "App_demo_test_job_docker"
  20.         job_desc.Description = "Test of create app job."
  21.         job_desc.Type = 'App'
  23.         job_desc.App.AppName = 'DemoApp_Docker'
  25.         job_desc.App.Config.InstanceType = "ecs.sn2.medium"
  27.         job_desc.App.Inputs["inputparam1"] = "oss://bucket-name/bc_test/input/";
  28.         job_desc.App.Inputs["inputparam2"] = "abcd1234";
  29.         job_desc.App.Outputs["output"] = "oss://bucket-name/bc_test/output/"
  31.         job_desc.App.Logging.StdoutPath = LOG_PATH
  32.         job_desc.App.Logging.StderrPath = ERR_PATH
  34.         job_id = client.create_job(job_desc).Id
  35.         print('App job created: %s' % job_id)
  36.     except ClientError, e:
  37.         print (e.get_status_code(), e.get_code(), e.get_requestid(), e.get_msg())
  38. if __name__ == '__main__':
  39.     sys.exit(main())
上一篇：如何创建 App下一篇：如何提交App作业