in src/main/java/com/aliyun/cloudops/acs/ecs/controller/OpsTaskController.java [67:83]
public ResponseEntity<RunCommandResponse> runCommand(
@PathVariable(name = "regionId") String regionId,
@RequestBody RunCommandRequest request
) throws ClientException {
request.setSysRegionId(regionId);
if (request.getParameters() != null) {
request.setEnableParameter(true);
}
// 使用云助手执行命令
RunCommandResponse response = this.cloudAssistant.runCommand(request, true);
String invokeId = response.getInvokeId();
this.saveTask(request, response);
// 创建一个异步的任务轮询任务,并在回调中处理查询到的结果
this.cloudAssistant.scheduleTaskQuery(regionId, invokeId, this);
return new ResponseEntity<>(response, HttpStatus.OK);
}