Serverless 工程实践 | Serverless 应用开发观念的转变

f = request.files['file']f.save('my_file_path')

AccessKey = {    "id": '',    "secret": ''}OSSConf = {    'endPoint': 'oss-cn-hangzhou.aliyuncs.com',    'bucketName': 'bucketName',    'objectSignUrlTimeOut': 60}#获取/上传文件到OSS的临时地址auth = oss2.Auth(AccessKey['id'], AccessKey['secret'])bucket = oss2.Bucket(auth, OSSConf['endPoint'], OSSConf['bucketName'])#对象存储操作getUrl = lambda object, method: bucket.sign_url(method, object, OSSConf['object    SignUrlTimeOut'])getSignUrl = lambda object: getUrl(object, "GET")putSignUrl = lambda object: getUrl(object, "PUT")
#获取随机字符串randomStr = lambda len: "".join(random.sample('abcdefghijklqrstuvwxyz123456789    ABCDEFGZSA' * 100, len))

#文件上传# URI: /file/upload# Method: POST@bottle.route('/file/upload', "POST")def postFileUpload():    try:        pictureBase64 = bottle.request.GET.get('picture', '').split("base64,")[1]        object = randomStr(100)        with open('/tmp/%s' % object, 'wb') as f:            f.write(base64.b64decode(pictureBase64))        bucket.put_object_from_file(object, '/tmp/%s' % object)        return response({            "status": 'ok',        })    except Exception as e:        print("Error: ", e)        return response(ERROR['SystemError'], 'SystemError')

#获取文件上传地址# URI: /file/upload/url# Method: GET@bottle.route('/file/upload/url', "GET")def getFileUploadUrl():    try:        object = randomStr(100)        return response({            "upload": putSignUrl(object),            "download": 'https://download.xshu.cn/%s' % (object)        })    except Exception as e:        print("Error: ", e)        return response(ERROR['SystemError'], 'SystemError')

<div style="width: 70%">    <div style="text-align: center">        <h3>Web端上传文件</h3>    </div>    <hr>    <div>        <p>            方案1：上传到函数计算进行处理再转存到对象存储，这种方法比较直观，问题是 FaaS 平                   台与 API 网关处有数据包大小上限，而且对二进制文件处理并不好。        </p>        <input type="file" name="file" id="fileFc"/>        <input type="button" onclick="UpladFileFC()" value="上传"/>    </div>    <hr>    <div>        <p>            方案2：直接上传到对象存储。流程是先从函数计算获得临时地址并进行数据存储（例如将                   文件信息存到 Redis 等），然后再从客户端将文件上传到对象存储，之后通过对象                   存储触发器触发函数，从存储系统（例如已经存储到 Redis）读取到信息，再对图                   像进行处理。        </p>        <input type="file" name="file" id="fileOss"/>        <input type="button" onclick="UpladFileOSS()" value="上传"/>    </div></div>

function UpladFileFC() {    const oFReader = new FileReader();    oFReader.readAsDataURL(document.getElementById("fileFc").files[0]);    oFReader.onload = function (oFREvent) {        const xmlhttp = window.XMLHttpRequest ? (new XMLHttpRequest()) : (new            ActiveXObject("Microsoft.XMLHTTP"))        xmlhttp.onreadystatechange = function () {            if (xmlhttp.readyState == 4 && xmlhttp.status == 200) {                alert(xmlhttp.responseText)            }        }        const url = "https://domain.com/file/upload"        xmlhttp.open("POST", url, true);        xmlhttp.setRequestHeader("Content-type", "application/json");        xmlhttp.send(JSON.stringify({            picture: oFREvent.target.result        }));    }}

function doUpload(bodyUrl) {    const xmlhttp = window.XMLHttpRequest ? (new XMLHttpRequest()) : (new Active        XObject("Microsoft.XMLHTTP"));    xmlhttp.open("PUT", bodyUrl, true);    xmlhttp.onload = function () {        alert(xmlhttp.responseText)    };    xmlhttp.send(document.getElementById("fileOss").files[0]);}

function UpladFileOSS() {    const xmlhttp = window.XMLHttpRequest ? (new XMLHttpRequest()) : (new Active        XObject("Microsoft.XMLHTTP"))    xmlhttp.onreadystatechange = function () {        if (xmlhttp.readyState == 4 && xmlhttp.status == 200) {            const body = JSON.parse(xmlhttp.responseText)            if (body['url']) {                doUpload(body['url'])            }        }    }    const getUploadUrl = 'https://domain.com/file/upload/url'    xmlhttp.open("POST", getUploadUrl, true);    xmlhttp.setRequestHeader("Content-type", "application/json");    xmlhttp.send();}