RESTful API

Elastic-Job-Cloud提供APP发布及作业注册等RESTful API可通过curl操作。

发布作业应用

url：app

方法：POST

参数类型：application/json

参数列表：

属性名类型是否必填缺省值描述
appNameString是作业应用名称。为Elastic-Job-Cloud的作业应用唯一标识
appURLString是作业应用所在路径。必须是可以通过网络访问到的路径
cpuCountdouble否1作业应用启动所需要的CPU数量
memoryMBdouble否128作业应用启动所需要的内存MB
bootstrapScriptString是启动脚本，如：bin\start.sh
appCacheEnablebool否true每次执行作业时是否从缓存中读取应用。禁用则每次执行任务均从应用仓库下载应用至本地
eventTraceSamplingCountint否0常驻作业事件采样率统计条数，默认不采样全部记录。为避免数据量过大，可对频繁调度的常驻作业配置采样率，即作业每执行N次，才会记录作业执行及追踪相关数据
  1. curl -l -H "Content-type: application/json" -X POST -d '{"appName":"foo_app","appURL":"http://app_host:8080/foo-job.tar.gz","cpuCount":0.1,"memoryMB":64.0,"bootstrapScript":"bin/start.sh","appCacheEnable":true,"eventTraceSamplingCount":0}' http://elastic_job_cloud_host:8899/api/app

修改作业应用配置

url：app

方法：PUT

参数类型：application/json

参数列表：

属性名类型是否必填缺省值描述
appNameString是作业应用名称。为Elastic-Job-Cloud的作业应用唯一标识
appCacheEnablebool是true每次执行作业时是否从缓存中读取应用。禁用则每次执行任务均从应用仓库下载应用至本地
eventTraceSamplingCountint否0常驻作业事件采样率统计条数，默认不采样全部记录。为避免数据量过大，可对频繁调度的常驻作业配置采样率，即作业每执行N次，才会记录作业执行及追踪相关数据
  1. curl -l -H "Content-type: application/json" -X PUT -d '{"appName":"foo_app","appCacheEnable":true}' http://elastic_job_cloud_host:8899/api/app

注册作业

url：job/register

方法：POST

参数类型：application/json

参数列表：

属性名类型是否必填缺省值描述
jobNameString是作业名称。为Elastic-Job-Cloud的作业唯一标识
appNameString是作业应用名称。
jobClassString是作业实现类
jobTypeEnum是作业类型。SIMPLE，DATAFLOW，SCRIPT
jobExecutionTypeEnum是作业执行类型。TRANSIENT为瞬时作业，DAEMON为常驻作业
cronString是cron表达式，用于配置作业触发时间
shardingTotalCountint是作业分片总数
cpuCountdouble是单片作业所需要的CPU数量，最小值为0.001
memoryMBdouble是单片作业所需要的内存MB，最小值为1
shardingItemParametersString否分片序列号和参数用等号分隔，多个键值对用逗号分隔
分片序列号从0开始，不可大于或等于作业分片总数
如：
0=a,1=b,2=c
jobParameterString否作业自定义参数
作业自定义参数，可通过传递该参数为作业调度的业务方法传参，用于实现带参数的作业
例：每次获取的数据量、作业实例从数据库读取的主键等
failoverboolean否false是否开启失效转移，开启表示如果作业在一次任务执行中途宕机，允许将该次未完成的任务在另一作业节点上补偿执行
misfireboolean否false是否开启错过任务重新执行
beanNameString否Spring容器中配置的bean名称
applicationContextString否Spring方式配置Spring配置文件相对路径以及名称，如：META-INF\applicationContext.xml
streamingProcessboolean否falseDATAFLOW类型作业，是否流式处理数据
如果流式处理数据, 则fetchData不返回空结果将持续执行作业
如果非流式处理数据, 则处理数据完成后作业结束
scriptCommandLineString否SCRIPT类型作业命令行执行脚本
jobPropertiesString否作业定制化属性，目前支持job_exception_handler和executor_service_handler，用于扩展异常处理和自定义作业处理线程池
descriptionString否作业描述信息

注册的作业可用Java和Spring两种启动方式，作业启动在开发指南中有说明，这里只举例说明两种方式如何注册。

使用Transient的Script类型作业可直接将shell上传至appURL，而无需打成java包。如果只有单个shell文件可无需压缩。如是复杂shell或python等应用，仍可上传tar包，支持各种常见压缩格式。

Java启动方式作业注册

  1. curl -l -H "Content-type: application/json" -X POST -d '{"jobName":"foo_job","appName":"foo_app","jobClass":"yourJobClass","jobType":"SIMPLE","jobExecutionType":"TRANSIENT","cron":"0/5 * * * * ?","shardingTotalCount":5,"cpuCount":0.1,"memoryMB":64.0,"failover":true,"misfire":true}' http://elastic_job_cloud_host:8899/api/job/register

Spring启动方式作业注册

  1. curl -l -H "Content-type: application/json" -X POST -d '{"jobName":"foo_job","appName":"foo_app","jobClass":"yourJobClass","beanName":"yourBeanName","applicationContext":"applicationContext.xml","jobType":"SIMPLE","jobExecutionType":"TRANSIENT","cron":"0/5 * * * * ?","shardingTotalCount":5,"cpuCount":0.1,"memoryMB":64.0,"failover":false,"misfire":true}' http://elastic_job_cloud_masterhost:8899/api/job/register

修改作业配置

url：job/update

方法：PUT

参数类型：application/json

参数：同注册作业

  1. curl -l -H "Content-type: application/json" -X PUT -d 
  2. '{"jobName":"foo_job","appName":"foo_app","jobClass":"yourJobClass","jobType":"SIMPLE","jobExecutionType":"TRANSIENT","cron":"0/5 * * * * ?","shardingTotalCount":5,"cpuCount":0.1,"memoryMB":64.0,"failover":true,"misfire":true}' http://elastic_job_cloud_host:8899/api/job/update

注销作业

url：job/deregister

方法：DELETE

参数类型：application/json

参数：作业名称

  1. curl -l -H "Content-type: application/json" -X DELETE -d 'foo_job' http://elastic_job_cloud_host:8899/api/job/deregister

触发一次作业

url：job/trigger

方法：POST

参数类型：application/json

参数：作业名称

说明：即事件驱动，通过调用API而非定时的触发作业。目前仅对Transient作业类型生效。

  1. curl -l -H "Content-type: application/json" -X POST -d 'foo_job' http://elastic_job_cloud_host:8899/api/job/trigger