流预测

本文档描述流预测相关接口。包括：CreateStreamPredict、StartStreamPredict、StopStreamPredict、DescribeStreamPredictResult、DescribeStreamPredicts、DeleteStreamPredict。

初始化

String region = "<RegionId>";
String accessKeyId = "<AccessKeyId>";
String accessKeySecret = "<AccessKeySecret>";
DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
client = new DefaultAcsClient(profile);

创建流预测

可以直接通过CreateStreamPredict接口创建流预测。

CreateStreamPredictRequest request = new CreateStreamPredictRequest();
// 流类型，Live：直播流，VS：监控流。
request.setStreamType("Live");
// 直播流的流ID，从直播平台获取。
request.setStreamId("<streamId>");
// 流截图存储地址前缀。如：http://test-bucket.oss-cn-beijing.aliyuncs.com/test/
request.setOutput("http://test-bucket.oss-cn-beijing.aliyuncs.com/test/");
// 流预测通知配置，支持MNS Queue，如：{"MNSQueue":"test-queue"}
request.setNotify("{\"MNSQueue\":\"test-queue\"}");
// 预测的模型ID列表，最多5个，支持系统模型和训练模型。
request.setModelIds("<modelId>");
// 是否自动开始预测，"true"：自动开始，"false"手动开始。
request.setAutoStart("false");
// 如果出错，可能会抛出ClientException或ServerException异常
CreateStreamPredictResponse response = client.getAcsResponse(request);
System.out.println("PredictId:" + response.getPredictId());

开始流预测

可以直接通过StartStreamPredict接口开始流预测。

StartStreamPredictRequest request = new StartStreamPredictRequest();
// 创建流预测时，会返回流预测ID。
request.setPredictId(predictId);
// 如果出错，可能会抛出ClientException或ServerException异常
StartStreamPredictResponse response = client.getAcsResponse(request);
System.out.println("PredictId:" + response.getPredictId());

结束流预测

通过StopStreamPredict接口结束流预测。

StopStreamPredictRequest request = new StopStreamPredictRequest();
// 创建流预测时，会返回流预测ID。
request.setPredictId(predictId);
// 如果出错，可能会抛出ClientException或ServerException异常
StopStreamPredictResponse response = client.getAcsResponse(request);
System.out.println("PredictId:" + response.getPredictId());

查询流预测结果

通过DescribeStreamPredictResult接口查询流预测结果。

DescribeStreamPredictResultRequest request = new DescribeStreamPredictResultRequest();
request.setPredictId(predictId);
request.setModelId(modelId);
// 如果出错，可能会抛出ClientException或ServerException异常
DescribeStreamPredictResultResponse response = client.getAcsResponse(request);
for (DescribeStreamPredictResultResponse.StreamPredictData data : response.getStreamPredictDatas()) {
    System.out.println("StreamPredictResult:" + JSON.toJSONString(data));
}

查询流预测列表

通过DescribeStreamPredicts接口查询流预测列表。

DescribeStreamPredictsRequest request = new DescribeStreamPredictsRequest();
// 如果为空，会列出所有的流预测列表
request.setPredictIds(predictId);
// 如果出错，可能会抛出ClientException或ServerException异常
DescribeStreamPredictsResponse response = client.getAcsResponse(request);
for (DescribeStreamPredictsResponse.StreamPredict streamPredict : response.getStreamPredicts()) {
    System.out.println("StreamPredict:" + JSON.toJSONString(streamPredict));
}

删除流预测

通过DeleteStreamPredict接口删除流预测。

DeleteStreamPredictRequest request = new DeleteStreamPredictRequest();
request.setPredictId(predictId);
// 如果出错，可能会抛出ClientException或ServerException异常
DeleteStreamPredictResponse response = client.getAcsResponse(request);
System.out.println("StreamPredictId:" + response.getPredictId());