直播/监控流预测

准备阶段：

• 开通直播/监控服务，并且已经将流推送到直播/监控平台。
• 将直播流/监控流的ID拼接出来，调用智能视觉接口进行流预测。
• 已经在智能视觉里，训练出自己的模型（图片分类，或者物体检测）或系统模型。

StreamId 如何获取：

• 推流到直播服务获取StreamId：
  • 从直播API或者控制台取到StreamId。如何获取，见直播帮助文档里的如何拼接推流地址。
• 推流到监控服务获取StreamId：
  • 从监控API查询流信息接口获取相应App、PlayDomain、Name；streamId拼接规则为：rtmp://PlayDomain/App/Name

下面将以直播流为例，描述对直播流进行预测的场景。

1. 获取需要进行预测的流StreamId

2. 创建流预测接口。

CreateStreamPredictRequest request = new CreateStreamPredictRequest();
// 直播控制台拷贝出来的StreamId。
request.setStreamId(streamId);
// 设置视频流来源, 监控服务:VS, 直播服务:Live
request.setStreamType("Live");
// 检测的模型，可以通过获取迭代列表接口"DescribeIterations"获取迭代的模型ID，一次最多支持5个模型的检测。
request.setModelIds(modelId);
// 设置推流到VS或者Live, 是否自动触发识别任务
request.setAutoStart("false");
// 流预测时，保存结果有问题的地址前缀。
request.setOutput("http://ivison-test.oss-cn-beijing.aliyuncs.com/ivision-test/");
// 配置消息通知，当前只支持MNS队列。
JSONObject notify = new JSONObject();
notify.put("MNSQueue", "ivison-test-queue");
request.setNotify(notify.toJSONString());
CreateStreamPredictResponse response = vars.getClient().getAcsResponse(request);
String predictId = response.getPredictId();

3. 开始流预测。

StartStreamPredictRequest request = new StartStreamPredictRequest();
// 创建流预测时，返回的预测ID。
request.setPredictId(predictId);
StartStreamPredictResponse response = vars.getClient().getAcsResponse(request);

4. 接收流预测消息。

MNS如何接收消息见MNS收消息示例代码。具体的消息格式见预测流消息回调格式说明。

// 收到的消息，转换为列表
JSONArray resultArray = JSONObject.parseArray(message.getMessageBodyAsString());

5. 查询流预测结果。

DescribeStreamPredictResultRequest request = new DescribeStreamPredictResultRequest();
request.setPredictId(predictId);
request.setModelId(vars.getModelId());
request.setAcceptFormat(FormatType.JSON);
DescribeStreamPredictResultResponse response;
do {
    response = vars.getClient().getAcsResponse(request);
    for (DescribeStreamPredictResultResponse.StreamPredictData data : response.getStreamPredictDatas()) {
        System.out.println(JSON.toJSONString(data));
    }
    request.setNextPageToken(response.getNextPageToken());
} while(response.getNextPageToken() != null) ;

6. 停止流预测。

StopStreamPredictRequest request = new StopStreamPredictRequest();
request.setPredictId(predictId);
StopStreamPredictResponse response = vars.getClient().getAcsResponse(request);

7. 查询流预测列表

DescribeStreamPredictsRequest request = new DescribeStreamPredictsRequest();
request.setPredictIds(predictId);
DescribeStreamPredictsResponse response = vars.getClient().getAcsResponse(request);
List<DescribeStreamPredictsResponse.StreamPredict> streamPredicts = response.getStreamPredicts();
for (DescribeStreamPredictsResponse.StreamPredict streamPredict : streamPredicts) {
    System.out.println(JSON.toJSONString(streamPredict));
}

8. 删除流预测消息。

DeleteStreamPredictRequest request = new DeleteStreamPredictRequest();
request.setPredictId(predictId);
DeleteStreamPredictResponse response = vars.getClient().getAcsResponse(request);