利用阿里云Eventbridge在CDN边缘应用程序中访问日志服务SLS-阿里云开发者社区

利用阿里云Eventbridge在CDN边缘应用程序中访问日志服务SLS

2022-10-14 339

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

日志服务 SLS，月写入数据量 50GB 1个月

简介： 在Web前端领域，追求极致性能是个永恒的话题。这些年的一些新兴理念都是为了提升站点访问性能而提出，无论是Jamstack技术理念或者或者 ESR (边缘渲染),都是Client侧进行性能优化的基础上，进一步拓展到了网络Infra层面，就是我们现在经常讨论的边缘计算。而阿里云的CDN EdgeRoutine 就是为广大客户提供可自由编程的边缘计算能力，我们可以用他来构建边缘节点的网关应用，来访问静态资源或者后端服务。当这个边缘网关在业务上承担的角色越来越重要的时候，我们就对他内部的业务逻辑产生了可观测的诉求，希望能够记录日志到日志服务上，然而日志服务提供的SDK，在ER的环境中暂时不被支持，这个

一图说明

简单来说，我们只需要在eb程序中用原生fetch方法, 向由eb创建的endpoint发起请求即可，其余的都交给eb转发给sls。

操作步骤

开通EB并且创建一条自定义总线
在自定义总线中创建 HTTP/HTTPS触发的事件源
创建一个可以处理这个http事件源的事件规则
选择“日志服务”的事件目标，（需要提前准备好相同region 下的sls project 和logstore）

需要特别注意的是，刚eb需要你提供一个授权角色来对sls进行操作，这里可以点击“授权创建新角色”进入阿里云RAM界面创建Eventbridge的授信角色，RAM创建授信角色的教程放到附录。之后点击角色配置右边的刷新按钮，就可以看到创建好的角色，选中即可

5.查看事件源中的 HTTP/HTTPS触发信息，复制公网请求URL

6.在ER应用程序中增加访问eb的代码(下方代码59行)

constinit= {
headers: {
"content-type": "text/html;charset=UTF-8",
    },
}
constAPI_ROUTER_REG=/^\/(prod-api|api)/g;
constUPLOAD_ROUTER_REG=/^\/(uploads)\/?/g;
constADMIN_OR_PORTAL_ROUTER_REG=/^\/(admin|portal)\/?/g;
constAPI_PATH='/api';
constGET_TYPE= { type: "text" };
asyncfunctiongatherResponse(response) {
constheaders=response.headersconstcontentType=headers.get("content-type") ||""if (contentType.includes("application/json")) {
returnJSON.stringify(awaitresponse.json())
    } elseif (contentType.includes("application/text")) {
returnresponse.text()
    } elseif (contentType.includes("text/html;charset=UTF-8")) {
returnresponse.text()
    } else {
returnresponse.blob()
    }
}
asyncfunctionhandleRequest(request) {
try {
constrequestHeaders=request.headers||init;
constedgeKv=newEdgeKV({ namespace: "myweb"});
conststaticUrl=awaitedgeKv.get('staticUrl', GET_TYPE);
constapiUrl=awaitedgeKv.get('apiUrl', GET_TYPE);
constportalUrl=awaitedgeKv.get('portalUrl', GET_TYPE);
constebUrl=awaitedgeKv.get('ebUrl', GET_TYPE);
constbody=request.body;
constmethod=request.method;
consturl=newURL(request.url)
const { pathname, search } =url;
letresponse= {};
if (pathname.match(API_ROUTER_REG)) {
constmatchedData=pathname.match(API_ROUTER_REG)[0];
letfinalurl= (apiUrl+pathname+search).replace(matchedData, API_PATH);
response=awaitfetch(finalurl, { headers: requestHeaders, method,body });
        } elseif (pathname.match(UPLOAD_ROUTER_REG)) {
letfinalurl=apiUrl+pathname+search;
response=awaitfetch(finalurl, { headers: requestHeaders, method ,body})
        }  elseif(pathname.match(ADMIN_OR_PORTAL_ROUTER_REG)){
letfinalurl=staticUrl+pathname+search;
response=awaitfetch(finalurl, { headers: requestHeaders, method });
        } else {
letfinalurl=portalUrl+pathname+search;
response=awaitfetch(finalurl, init);
        }
constresults=awaitgatherResponse(response)
constfinalResponse=newResponse(results, response.headers);
try { // 这里开始插入访问eb的代码awaitfetch(ebUrl, {method,body:JSON.stringify({path: pathname}) });
        }catch(e){}
returnfinalResponse;
    } catch (e) {
returnnewResponse(JSON.stringify({ message: e.message }), {
headers: {
"content-type": "application/json;charset=UTF-8"            }
        })
    }
}
addEventListener("fetch", event=> {
returnevent.respondWith(handleRequest(event.request))
})