本文介绍触发器的高级系统功能。

使用说明

本文介绍的高级功能只适用于自定义事件源触发器,包括MNS队列触发器RocketMQ触发器RabbitMQ触发器Kafka触发器

调用方式

函数计算的触发器支持同步调用和异步调用两种调用方式。两种调用方式的限制如下所示。
调用模式 body大小 超时时间上限
同步调用 16 MB 5分钟
异步调用 128 KB 5分钟

批量推送

说明 批量推送需结合body大小限制决定是否减少聚合消息数。关于body大小限制,请参见调用方式

概念解释

开启批量推送后,需设置批量推送条数推量推送间隔

  • 批量推送条数:一次调用函数发送的最大批量消息条数,当积压的消息数量到达设定值时才会发送请求。取值范围为[1, 500]。
  • 推量推送间隔:调用函数的时间间隔,系统每到间隔时间点会将消息聚合后发给函数计算。取值范围为[0,15],单位为秒。0秒表示无需等待,实时投递。

批量推送帮助您批量聚合多个事件,当批量推送条数推量推送间隔两者条件满足其中一个时,触发函数执行,将请求消息批量推送到函数计算

批量推送案例

  • 案例一

    您设置的批量推送条数为100条,每条消息大小为1 KB,推量推送间隔为15s。在10s内消息条数累积100条,则立即触发推送,无需等到15s再推送。

  • 案例二

    您设置的批量推送条数为100条,每条消息大小为1 KB,推量推送间隔为15s。在15s内消息积累50条,则立即触发推送,无需等待消息积累到100条后再推送。

  • 案例三

    您设置的批量推送条数为100条,每条消息大小为2 KB,推量推送间隔为15s,调用方式异步调用。在10s内消息积累100条(消息累积大小100*2KB=200KB),达到异步调用body大小限制数,则立即触发推送,第一批聚合64条消息推送到函数计算,第二批聚合36条消息推送到函数计算

重试策略

函数请求在部分失败场景下,可按配置的重试策略进行重试。重试策略选项如下。
  • 退避重试:重试3次,每次重试的时间间隔为介于10s~20s的随机值。
  • 指数衰减重试:默认重试策略。重试176次,每次重试的时间间隔按照指数递增至512s,总计重试时间为24小时,即重试时间间隔为1s、2s、4s、8s、16s、32s、64s、128s、256s、512s……512s(共计167次间隔512s)。

触发重试的场景

  • 429错误:指请求被函数计算限流。限流是短暂的,因此会触发重试。
  • 5xx错误:指函数计算系统异常导致函数无法执行。

常见问题FAQ

Q:因函数实现问题引发的函数执行出错是否会触发执行重试策略?

A:不会。函数计算无法在系统层面区分函数运行出错的类型,因此函数执行出错不会触发重试策略。

函数运行出错重试包含以下两种类型。
  • 可能重试成功

    无需执行重试策略,可以在函数内实现重试。

  • 不可能重试成功

    重试无意义,只会增加重试成本。

容忍策略

容忍策略,即发生错误时是否选择容错。
  • 允许容错

    请求失败且重试失败后,跳过此请求,继续处理下一条请求。

  • 禁止容错

    请求失败且重试失败后,消费任务阻塞。

死信队列

仅当开启允许容错时,可配置死信队列。
  • 如果启用死信队列,未被处理或超过重试次数的消息会被投递到目标服务中。函数计算支持的目标服务包括消息服务MNS和消息队列RocketMQ版,您可以根据需求选择MNS队列或RocketMQ实例。
  • 如果未启用死信队列,超过重试次数的消息会被丢弃。

并发消费

您可以通过设置并发消费线程数提高吞吐,目前仅Kafka触发器支持设置并发配额消息队列Kafka版并发消费需配合Topic分区共同实现,包括以下几种场景。
  • Topic分区数=并发消费数:一个线程消费一个Topic分区。
  • Topic分区数>并发消费数:多个并发消费会均摊所有分区消费。
  • Topic分区数<并发消费数:一个线程消费一个Topic分区,多出的消费数无效。
说明 为保证您的资源被充分利用,建议您选择Topic分区数=并发消费数或Topic分区数>并发消费数场景。