微服务与事件驱动架构

使用

“

函数即服务

”

的微服务

｜

125

虽然前面的例子中没有展示，但是也可以将函数结果输出到它们自己的事件流中，不只是

为了输出数据，也是为了跟踪函数是否成功调用。

同步

触发器在函数处理完一批事件之后才会发出下一批事件。这对于保证处理顺序是相当

重要的，并且受限于被处理的事件流的并行度。相反，

异步

触发可以发送多个事件到多个

函数，每个函数在完成处理之后返回。但是，这将无法保证处理的顺序，并且只能用于处

理顺序对业务逻辑不重要的场景。

在流监听触发器中，

批量大小

和

批量窗口

是需要考虑的两个重要属性。批量大小表明了发

送给函数处理的事件的最大数量，批量窗口表明了等待额外事件的最长时间，而不是立即

触发函数。这两个参数都用于确保在批记录中分配启动函数的开销，以降低启动成本。

由流监听触发器函数执行的示例代码如下所示。

public int myEventfunction(Event[] events, Context context) {

for(Event event: events)

try {

println (event.key + ", " + event.value);

} catch (Exception e) {

println ("error printing " + event.toString);

}

//向FaaS框架表明批处理已经完成

context.success();

return 0;

}

与容器化的微服务类似，事件流监听器模式的触发器可以配置成从流的最新