互动视频审核

互动视频审核针对视频直播互动解决方案，提供配套的视频流实时审核服务，检测视频流中的不良信息，并给出审核结果管控建议。
针对房间（roomId）启动审核任务后，系统会自动从传输系统拉取视频数据，周期性截图进行识别。

1. 功能描述

互动视频审核服务检测实时视频流的违规信息，异步回调返回违规结果。

提供以下审核类别action和对应的标签label：

2. 使用限制

3. 接口说明

3.1 启动任务

发起请求

请求内容

1. 审核任务以roomId作为唯一标识，同一个roomId启动多次审核任务，系统将返回错误
2. 需要更新任务审核配置，请先停止现有审核任务

响应内容

响应报文body中的数据是JSON，具体字段说明如下：

3.2 结果回调

回调时机

1）当检测到实时流包含出现违规信息时，调用resultCallback提供的地址，通知用户放检测结果；
2）当检测任务中指定roomid所有直播流都已经超时超过10分钟时，调用statusCallback提供的地址，通知用户方任务状态。

• 启动任务resultCallback和statusCallback可以为空，为空时用户可以通过查询接口获得任务状态和结果；
• 用户如果需要使用回调方式获得结果和任务状态，必须保证回调HTTP服务工作稳定；
• 当回调地址访问失败 或者 返回状态码非200，后台将 最多重试5次 。

回调方式

使用 HTTPS POST 方式访问用户提供的url地址，状态和结果以JSON串格式填在http请求body中，具体格式见下一小节。
为了防止内容被篡改，在http请求header增加一个checksum项用于校验内容是否合法。

checksum串的生成方式如下：

启动任务参数携带的sequence + body字符串数据，通过SHA256算法生成checksum值

识别结果回调

表. result

(1)当action为sface时，result->extraData数组中元素结构如下

表. sface-extraData

(2)当action为porn时，result->extraData数组中元素结构如下

表. porn-extraData

任务状态回调

3.3 查询检测结果

请求方式

返回内容

表. results

3.4 停止检测任务

请求方式

响应内容

返回body中的数据是JSON，具体字段说明如下：

3.5 查询任务列表

业务方可通过http请求获取到当前任务列表信息，以下为请求方式说明：

请求方式

响应内容

返回body中的数据是JSON，具体字段说明如下：

表. task

4. 调用示例

以下是python代码的调用例子演示

4.1 请求启动任务

# -*- coding: utf-8 -*-
#! python3.5

import requests
import uuid
import base64

host = "https://ai.jocloud.com"

appid = 1234567890              # 您的业务ID
restful_id = '**********'       # 您的证书ID
restful_secret = '**********'   # 您的证书秘钥

traceid = str(uuid.uuid4())
roomid = 'test-room-1'

# url
url = host + '/app/%s/v1/video/stream/start?traceId=%s' % (appid, traceid)

# headers
headers = {
    "content-type": "application/json"
}

auth = base64.b64encode(("%s:%s" % (restful_id, restful_secret)).encode('utf-8'))
headers['token'] = 'Base ' + auth.decode()

# 业务放需要使用到的上下文信息，便于在回调消息中协助后续处理，例如：
context = {
    'myid': 123,
    'myname': 'test'
}

# 识别结果及状态的回调地址，识别结果及状态通知将会通过http POST回调
resultCallback = 'http://192.168.1.100:12345/result'
statusCallback = 'http://192.168.1.100:12345/status'

# content
values = {
    'roomId': roomid,
    'uids': [],
    'context': context,
    'actions': ['porn'],
    'resultCallback': resultCallback,
    'statusCallback': statusCallback,
    'sequence': 'test'
}

# request
res = requests.post(url, json=values, headers=headers)
print ('code=%s, data=%s\n' % (res.status_code, res.text))

调用结果返回如下：

{
    "code": 200,
    "message": "OK",
    "traceId": "f35a8abb-db6c-48f2-af7e-f6c0921b7b0d",
    "roomId": "test-room-1",
    "timestamp": 1576567090,
    "context": {
        "myid": 123,
        "myname": "test"
    }
}

4.2 查询任务状态和结果

# -*- coding: utf-8 -*-
#! python3.5

import requests
import uuid
import base64

host = "https://ai.jocloud.com"

appid = 1234567890              # 您的业务ID
restful_id = '**********'       # 您的证书ID
restful_secret = '**********'   # 您的证书秘钥

traceid = str(uuid.uuid4())
roomid = 'test-room-1'

# url
url = host + '/app/%s/v1/video/stream/results?traceId=%s&roomId=%s' % (appid, traceid, roomid)

# headers
headers = {
    "content-type": "application/json"
}

auth = base64.b64encode(("%s:%s" % (restful_id, restful_secret)).encode('utf-8'))
headers['token'] = 'Base ' + auth.decode()

# request
res = requests.get(url, headers=headers)
print ('url=%s\ncode=%s\ndata=%s\n' % (url, res.status_code, res.text))

调用结果返回如下：

{
  "code": 200,
  "message": "OK",
  "traceId": "fe0a8278-0ed6-4c74-80ab-fb1066605227",
  "roomId": "test-room-1",
  "timestamp": 1576567239,
  "context": {
    "myid": 123,
    "myname": "test"
  },
  "results": [
    {
      "uid": 123456,
      "result": [
        {
          "action": "porn",
          "label": "normal",
          "rate": 0.99952548742294312,
          "suggestion": "pass",
          "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/cccc2dcc-5472-4fbf-ae1b-5a906ea46c46.jpg",
          "extraData": []
        }
      ],
      "timestamp": 1576567233
    }
  ],
  "status": "running"
}

4.3 停止任务

# -*- coding: utf-8 -*-
#! python3.5

import requests
import uuid
import base64

host = "https://ai.jocloud.com"

appid = 1234567890              # 您的业务ID
restful_id = '**********'       # 您的证书ID
restful_secret = '**********'   # 您的证书秘钥

traceid = str(uuid.uuid4())
roomid = 'test-room-1'

# headers
headers = {
    "content-type": "application/json"
}

auth = base64.b64encode(("%s:%s" % (restful_id, restful_secret)).encode('utf-8'))
headers['token'] = 'Base ' + auth.decode()

# url
url = host + '/app/%s/v1/video/stream/stop?traceId=%s&roomId=%s' % (appid, traceid, roomid)

# request
res = requests.post(url, json={}, headers=headers)
print ('url=%s\ncode=%s\ndata=%s\n' % (url, res.status_code, res.text))

调用结果返回如下：

{
    "code": 200,
    "message": "OK",
    "traceId": "9eb28f1d-a307-4e93-bcf4-66e531aa12f1",
    "roomId": "test-room-1",
    "context": {
        myid": 123,
        myname": "test"
    },
    "timestamp": 1576567306
}

5. 更新历史