【架构实战】FaaS实战：从函数计算到事件驱动

一、FaaS概述FaaS函数即服务是Serverless的核心特点无状态事件触发自动扩缩容按需付费二、主流FaaS平台1. 平台对比平台厂商特点LambdaAWS生态完善Function Compute阿里云国内生态好Cloud Functions腾讯云性价比高Cloud FunctionsGoogleKubernetes集成2. 开发对比// AWS Lambdaexports.handlerasync(event){return{statusCode:200,body:Hello};};// 阿里云FCmodule.exports.handlerasync(req,resp){resp.send(Hello);};// 腾讯云SCFexports.mainasync(event,context){returnHello;};三、事件驱动架构1. 事件源事件源类型 ├── HTTP请求 ├── 对象存储S3/OSS ├── 消息队列 ├── 数据库变更 ├── 定时任务 ├── 监控系统告警 └── CDN事件2. 事件处理// S3事件处理AWS Lambdaexports.handlerasync(event){for(constrecordofevent.Records){constbucketrecord.s3.bucket.name;constkeyrecord.s3.object.key;awaitprocessFile(bucket,key);}};// 消息队列处理exports.handlerasync(event){constmessagesJSON.parse(event.Records[0].body);for(constmsgofmessages){awaitprocessMessage(msg);}};四、函数编排1. AWS Step Functions{Comment:订单处理流程,StartAt:验证订单,States:{验证订单:{Type:Task,Resource:arn:aws:lambda:region:account:function:validateOrder,Next:库存检查},库存检查:{Type:Task,Resource:arn:aws:lambda:region:account:function:checkInventory,Next:创建订单},创建订单:{Type:Task,Resource:arn:aws:lambda:region:account:function:createOrder,End:true}}}2. 阿里云流程编排-name:order-flowtype:flowprops:region:cn-hangzhoudefinition:|start: type: pass next: validate validate: type: task resource: acs:fc:cn-hangzhou:srv:validate-order next: process process: type: task resource: acs:fc:cn-hangzhou:srv:process-order next: notify notify: type: task resource: acs:fc:cn-hangzhou:srv:send-notification next: end end: type: pass五、最佳实践1. 函数设计原则// 单一职责exports.handlerasync(event){returnawaitprocessEvent(event);};// 无状态设计exports.handlerasync(event){constuserIdevent.userId;constuserawaitdb.getUser(userId);returnuser;};// 错误处理exports.handlerasync(event){try{returnawaitprocess(event);}catch(error){console.error(Error:,error);thrownewError(Process failed);}};2. 日志追踪exports.handlerasync(event,context){constrequestIdcontext.requestId;logger.info(Function started,{requestId});try{constresultawaitprocess(event);logger.info(Function completed,{requestId});returnresult;}catch(error){logger.error(Function failed,{requestId,error});throwerror;}};六、应用场景1. 文件处理// 图片处理exports.handlerasync(event){consts3Eventevent.Records[0].s3;constbuckets3Event.bucket.name;constkeydecodeURIComponent(s3Event.object.key);constimageawaits3.getObject({Bucket:bucket,Key:key}).promise();constresizedawaitsharp(image.Body).resize(800).toBuffer();awaits3.putObject({Bucket:bucket,Key:resized/${key},Body:resized}).promise();};2. 实时数据处理// 日志分析exports.handlerasync(event){constlogsevent.records.map(rJSON.parse(r.data));conststatslogs.reduce((acc,log){acc[log.level](acc[log.level]||0)1;returnacc;},{});awaitmetrics.putMetricData({MetricData:Object.entries(stats).map(([level,count])({MetricName:LogLevel.${level},Value:count}))}).promise();};3. webhook处理// GitHub Webhookexports.handlerasync(event){constpayloadJSON.parse(event.body);switch(event.headers[x-github-event]){casepush:awaithandlePush(payload);break;casepull_request:awaithandlePullRequest(payload);break;caseissues:awaithandleIssue(payload);break;}return{statusCode:200};};七、总结FaaS与事件驱动函数最小执行单元事件触发函数执行编排组合复杂流程场景文件处理、实时计算、webhook个人观点仅供参考