更新时间:2019-03-29 18:09
本文档描述流预测相关接口。包括: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());
在文档使用中是否遇到以下问题
更多建议
匿名提交