add app

apidemo/TranslateDemo.py

@@ -0,0 +1,40 @@
+import requests
+import os
+from .utils.AuthV3Util import addAuthParams
+
+# 您的应用ID
+APP_KEY = os.environ.get("APP_KEY",None)
+# 您的应用密钥
+
+APP_SECRET = os.environ.get("APP_SECRET",None)
+
+
+def createRequest(msq):
+    '''
+    note: 将下列变量替换为需要请求的参数
+    '''
+    q = msq
+    lang_from = 'auto'
+    lang_to = 'en'
+    # vocab_id = '您的用户词表ID'
+
+    data = {'q': q, 'from': lang_from, 'to': lang_to}
+
+    addAuthParams(APP_KEY, APP_SECRET, data)
+
+    header = {'Content-Type': 'application/x-www-form-urlencoded'}
+    res = doCall('https://openapi.youdao.com/api', header, data, 'post')
+    print(str(res.content, 'utf-8'))
+    return str(res.content, 'utf-8')
+
+
+def doCall(url, header, params, method):
+    if 'get' == method:
+        return requests.get(url, params)
+    elif 'post' == method:
+        return requests.post(url, params, header)
+
+# 网易有道智云翻译服务api调用demo
+# api接口: https://openapi.youdao.com/api
+if __name__ == '__main__':
+    createRequest()

apidemo/utils/AuthV3Util.py

@@ -0,0 +1,55 @@
+import hashlib
+import time
+import uuid
+
+'''
+添加鉴权相关参数 -
+    appKey : 应用ID
+    salt : 随机值
+    curtime : 当前时间戳(秒)
+    signType : 签名版本
+    sign : 请求签名
+    
+    @param appKey    您的应用ID
+    @param appSecret 您的应用密钥
+    @param paramsMap 请求参数表
+'''
+def addAuthParams(appKey, appSecret, params):
+    q = params.get('q')
+    if q is None:
+        q = params.get('img')
+    salt = str(uuid.uuid1())
+    curtime = str(int(time.time()))
+    sign = calculateSign(appKey, appSecret, q, salt, curtime)
+    params['appKey'] = appKey
+    params['salt'] = salt
+    params['curtime'] = curtime
+    params['signType'] = 'v3'
+    params['sign'] = sign
+
+'''
+    计算鉴权签名 -
+    计算方式 : sign = sha256(appKey + input(q) + salt + curtime + appSecret)
+    @param appKey    您的应用ID
+    @param appSecret 您的应用密钥
+    @param q         请求内容
+    @param salt      随机值
+    @param curtime   当前时间戳(秒)
+    @return 鉴权签名sign
+'''
+def calculateSign(appKey, appSecret, q, salt, curtime):
+    strSrc = appKey + getInput(q) + salt + curtime + appSecret
+    return encrypt(strSrc)
+
+
+def encrypt(strSrc):
+    hash_algorithm = hashlib.sha256()
+    hash_algorithm.update(strSrc.encode('utf-8'))
+    return hash_algorithm.hexdigest()
+
+
+def getInput(input):
+    if input is None:
+        return input
+    inputLen = len(input)
+    return input if inputLen <= 20 else input[0:10] + str(inputLen) + input[inputLen - 10:inputLen]

apidemo/utils/AuthV4Util.py

@@ -0,0 +1,45 @@
+import hashlib
+import time
+import uuid
+
+'''
+添加鉴权相关参数 -
+    appKey : 应用ID
+    salt : 随机值
+    curtime : 当前时间戳(秒)
+    signType : 签名版本
+    sign : 请求签名
+    
+    @param appKey    您的应用ID
+    @param appSecret 您的应用密钥
+    @param paramsMap 请求参数表
+'''
+def addAuthParams(appKey, appSecret, params):
+    salt = str(uuid.uuid1())
+    curtime = str(int(time.time()))
+    sign = calculateSign(appKey, appSecret, salt, curtime)
+    params['appKey'] = appKey
+    params['salt'] = salt
+    params['curtime'] = curtime
+    params['signType'] = 'v4'
+    params['sign'] = sign
+
+
+'''
+    计算鉴权签名 -
+    计算方式 : sign = sha256(appKey + input(q) + salt + curtime + appSecret)
+    @param appKey    您的应用ID
+    @param appSecret 您的应用密钥
+    @param salt      随机值
+    @param curtime   当前时间戳(秒)
+    @return 鉴权签名sign
+'''
+def calculateSign(appKey, appSecret, salt, curtime):
+    strSrc = appKey + salt + curtime + appSecret
+    return encrypt(strSrc)
+
+
+def encrypt(strSrc):
+    hash_algorithm = hashlib.sha256()
+    hash_algorithm.update(strSrc.encode('utf-8'))
+    return hash_algorithm.hexdigest()

apidemo/utils/WebSocketUtil.py

@@ -0,0 +1,74 @@
+import sys
+import threading
+import urllib.parse
+
+import websocket
+
+"""
+    初始化websocket连接
+"""
+def init_connection(url):
+    ws = websocket.WebSocketApp(url, on_open=ClientThread.on_open, on_message=ClientThread.on_message,
+                                on_close=ClientThread.on_closed, on_error=ClientThread.on_error)
+    # 异步监听返回结果
+    client = ClientThread(ws=ws)
+    client.start()
+    return client
+
+
+"""
+    初始化websocket连接, 并附带相关参数
+"""
+def init_connection_with_params(url, params):
+    url_prams_builder = urllib.parse.urlencode(params)
+    url = url + '?' + url_prams_builder
+    return init_connection(url)
+
+
+"""
+    发送text message
+"""
+def send_text_message(ws, message):
+    ws.send(message)
+    print("send text message: " + message)
+
+
+"""
+    发送binary message
+"""
+def send_binary_message(ws, message):
+    ws.send(message, websocket.ABNF.OPCODE_BINARY)
+    print("send binary message length: " + str(len(message)))
+
+
+class ClientThread(threading.Thread):
+    def __init__(self, ws):
+        threading.Thread.__init__(self)
+        self.ws = ws
+        ws.is_connect = False
+
+    def run(self):
+        self.ws.run_forever()
+
+    def return_is_connect(self):
+        return self.ws.is_connect
+
+    def on_message(ws, message):
+        print("received message: " + message)
+        # 该判断方式仅用作demo展示, 生产环境请使用json解析
+        if "\"errorCode\":\"0\"" not in message:
+            sys.exit()
+
+    def on_open(ws):
+        print("connection open")
+        ws.is_connect = True
+
+    def on_closed(ws, close_status_code, close_msg):
+        if not close_status_code:
+            close_status_code = 'None'
+        if not close_msg:
+            close_msg = 'None'
+        print("connection closed, code: " + close_status_code + ", reason: " + close_msg)
+
+    def on_error(ws, error):
+        print(error)

app.py

@@ -0,0 +1,35 @@
+import os
+import gradio as gr
+import json
+# api_key = os.environ.get('OPENAI_KEY', None)
+from apidemo.TranslateDemo import createRequest
+
+def get_responce(msg):
+    
+    result_str = createRequest(msg)
+    result = json.loads(result_str)
+    return  result["translation"][0]
+    # pass
+
+with gr.Blocks() as demo:
+    chatbot = gr.Chatbot()
+    msg = gr.Textbox()
+    clear = gr.ClearButton([msg, chatbot])
+
+    def respond(message, chat_history):
+        bot_message = get_responce(message)
+        chat_history.append((message, bot_message))
+        # time.sleep(2)
+        return "", chat_history
+
+    msg.submit(respond, [msg, chatbot], [msg, chatbot])
+
+if __name__ == "__main__":
+    demo.launch()
+
+
+
+
+
+
+    

requirements.txt

@@ -0,0 +1 @@
+websocket