阿里云实时音视频

实时音视频为客户端创建令牌

from aliyunsdkcore.client import AcsClient
from aliyunsdkrtc.request.v20180111 import CreateChannelRequest
from aliyunsdkcore.acs_exception.exceptions import ServerException
import aliyunsdkcore.profile.region_provider as rtc_user_config
import aliyunsdkcore.request as rtc_request
import aliyunsdkcore.http.protocol_type as rtc_protocol_type
import json, uuid


# 频道认证
class ChannelAuth:
    def __init__(self):
        self.app_id = None
        self.channel_id = None
        self.nonce = None
        self.timestamp = None
        self.channel_key = None
        self.recovered = None
        self.request_id = None


# 恢复错误
def recover_for_error(ex, app_id, channel_id):
    fatal = False
    request_id = ""
    if isinstance(ex, ServerException):
        request_id = ex.get_request_id()
        code = ex.get_error_code()
        if code == "IllegalOperationApp":
            fatal = True
        elif code.startswith("InvalidAccessKeyId"):
            fatal = True
        elif code == "SignatureDoesNotMatch":
            fatal = True
    if fatal:
        raise ex
    recovered = "RCV-%s" % str(uuid.uuid4())
    print("Recover from %s, recovered=%s" % (ex, recovered))
    auth = ChannelAuth()
    auth.app_id = app_id
    auth.channel_id = channel_id
    auth.nonce = recovered
    auth.timestamp = 0
    auth.channel_key = recovered
    auth.request_id = request_id
    auth.recovered = True
    return auth


# 创建频道
def create_channel(app_id, channel_id,
                   access_key_id, access_key_secret, region_id, endpoint
                   ):
    try:
        client = AcsClient(access_key_id, access_key_secret, region_id)
        request = CreateChannelRequest.CreateChannelRequest()
        request.set_AppId(app_id)
        request.set_ChannelId(channel_id)

        # Use HTTP, x3 times faster than HTTPS.
        rtc_request.set_default_protocol_type(rtc_protocol_type.HTTP)

        response = client.do_action_with_exception(request)
        obj = json.loads(response)

        auth = ChannelAuth()
        auth.app_id = app_id
        auth.channel_id = channel_id
        auth.nonce = obj[\'Nonce\']
        auth.timestamp = obj[\'Timestamp\']
        auth.channel_key = obj[\'ChannelKey\']
        auth.request_id = obj[\'RequestId\']
        auth.recovered = False
        return auth
    except Exception as ex:
        return recover_for_error(ex, app_id, channel_id)


region_id = "cn-hangzhou"  # 地域
endpoint = "rtc.aliyuncs.com"  # 节点

app_id = \'sj17fi\'
channel_id = str(uuid.uuid4())
access_key_id = \'LTAIT0dog7\'
access_key_secret = \'8LOt6GqvvvvvvvPdvPcBXl\'

auth = create_channel(app_id, channel_id,
                      access_key_id, access_key_secret, region_id, endpoint
                      )

# print(r1)
# print(auth.channel_key)
# print(auth.nonce)
# print(auth.timestamp)

# 为客户端创建令牌
import uuid, hashlib


def create_user_id():
    return str(uuid.uuid4())


def create_token(channel_id, channel_key, app_id, user_id, nonce, timestamp):
    channel_id = channel_id.encode(\'utf-8\')
    channel_key = channel_key.encode(\'utf-8\')
    app_id = app_id.encode(\'utf-8\')
    user_id = user_id.encode(\'utf-8\')
    nonce = nonce.encode(\'utf-8\')
    timestamp = str(timestamp).encode(\'utf-8\')

    h = hashlib.sha256()
    h.update(channel_id)
    h.update(channel_key)
    h.update(app_id)
    h.update(user_id)
    h.update(nonce)
    h.update(timestamp)
    token = h.hexdigest()
    return token


userid = create_user_id()
token = create_token(channel_id, auth.channel_key, app_id,
                     userid, auth.nonce, auth.timestamp)

channels = {}

channels[\'AppID\'] = app_id
channels[\'channel_id\'] = channel_id
channels[\'userid\'] = userid
channels[\'Nonce\'] = auth.nonce
channels[\'Timestamp\'] = auth.timestamp
channels[\'Token\'] = channel_id
channels[\'GSLB\'] = \'https://rgslb.rtc.aliyuncs.com\'

print(channels)

# {
#     \'AppID\': \'sj1fu7fi\', \'channel_id\': \'02da1070-ec2a-4ebd-829f-4653e385b4a2\',
#  \'userid\': \'9072b3d7-e954-4fd4-b807-aa60bf1d83c3\', \'Nonce\': \'844bba6b89b5f9956f6a2a6fc33efde8\', \'Timestamp\': 1555379321,
#  \'Token\': \'02da1070-ec2a-4ebd-829f-4653e385b4a2\', \'GSLB\': \'https://rgslb.rtc.aliyuncs.com\'
# }