实时拉流审核

实时拉流审核用于检测实时音视频流中的不良信息，并给出审核结果管控建议。
采用检测方法是对视频流周期性抽帧，检测帧画面中的不良信息；对音频流周期性分段进行识别。目前支持对视频流和音频流进行识别。

1. 功能描述

调用方提交需要检测的实时音视频流，指定需要检测的类型，服务器周期性抽帧、切片检测回调返回检测结果。

视频流内容审核支持的检测类型及对应标签如下：

音频流支持的检测类型和对应标签如下：

2. 使用限制

3. 接口说明

3.1 启动任务

发起请求

请求内容

表. extra

响应参数

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

3.2 结果回调

回调时机

1）当检测到实时流包含出现违规信息时，调用resultCb提供的地址，通知用户放检测结果；
2）当检测任务出现异常情况，如拉流失败、解码失败是，调用statusCb提供的地址，通知用户方任务状态。

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

回调方式

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

checksum串的生成方式如下：

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

识别结果回调

表. result

表. v-porn-extraData

表. v-sface-extraData

表. a-porn-extraData

表. a-antispam-extraData

识别状态回调

3.3 查询结果

请求方式

返回内容

表2. results

3.4 停止检测任务

请求方式

返回参数

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

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())
dataid = str(uuid.uuid4())

# url
url = host + '/app/%s/v1/video/live/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()

# 需要识别的直播流地址
streamurl = 'rtmp://mytest.com/live/123456789'

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

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

# content
values = {
    'actions': ['v-porn'],
    'url': streamurl,
    'streamId': "demo-test",
    'resultCb': resultCb,
    'statusCb': statusCb,
    'sequence': 'test',
    'context': context
}

# 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",
    "taskId": "acee5522-b198-4325-9434-61b41eb2e08a",
    "timestamp": 1576567090,
    "streamId": "demo-test",
    "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 = '**********'  # 您的证书秘钥
task_id = "acee5522-b198-4325-9434-61b41eb2e08a"  # 这里填写启动任务时返回的taskId内容

traceid = str(uuid.uuid4())
dataid = str(uuid.uuid4())

# url
url = host + '/app/%s/v1/video/live/results?traceId=%s&taskId=%s' % (appid, traceid, task_id)

# 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",
    "taskId": "acee5522-b198-4325-9434-61b41eb2e08a",
    "timestamp": 1576567239,
    "streamId": "demo-test",
    "context": {
        "myid": 123,
        "myname": "test"
    },
    "results": [
        {
            "result": [
                {
                    "action": "v-porn",
                    "label": "normal",
                    "rate": 0.99952548742294312,
                    "suggestion": "pass",
                    "timestamp": 1576567232,
                    "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/cccc2dcc-5472-4fbf-ae1b-5a906ea46c46.jpg"
                }
            ],
            "timestamp": 1576567233
        },
        {
            "result": [
                {
                    "action": "v-porn",
                    "label": "normal",
                    "rate": 0.99910759925842285,
                    "suggestion": "pass",
                    "timestamp": 1576567227,
                    "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/f5540914-c5d4-41b6-8080-42a218f16a34.jpg"
                }
            ],
            "timestamp": 1576567228
        },
        {
            "result": [
                {
                    "action": "v-porn",
                    "label": "normal",
                    "rate": 0.9999052882194519,
                    "suggestion": "pass",
                    "timestamp": 1576567222,
                    "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/50bf73a6-2555-48c2-8f33-13d2002f7e76.jpg"
                }
            ],
            "timestamp": 1576567223
        },
        {
            "result": [
                {
                    "action": "v-porn",
                    "label": "normal",
                    "rate": 0.99971604347229004,
                    "suggestion": "pass",
                    "timestamp": 1576567217,
                    "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/4696a8a5-78f8-4c32-b696-aebbf79685bc.jpg"
                }
            ],
            "timestamp": 1576567218
        },
        {
            "result": [
                {
                    "action": "v-porn",
                    "label": "normal",
                    "rate": 0.99987661838531494,
                    "suggestion": "pass",
                    "timestamp": 1576567212,
                    "url": "http://jocloud-ai-openapi.oss-cn-hangzhou.aliyuncs.com/live/10034/6002efb8-e6d4-4527-afd8-1fd4a951d655.jpg"
                }
            ],
            "timestamp": 1576567213
        }
    ],
    "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())
dataid = str(uuid.uuid4())

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

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

traceid = str(uuid.uuid4())
task_id = 'acee5522-b198-4325-9434-61b41eb2e08a' # 这里填写启动任务时返回的taskId内容

# url
url = host + '/app/%s/v1/video/live/stop?traceId=%s&taskId=%s' % (appid, traceid, task_id)

# 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",
    "taskId": "acee5522-b198-4325-9434-61b41eb2e08a",
    "timestamp": 1576567306
}

5. 更新历史