消息队列Kafka版作为事件源通过事件总线EventBridge与函数计算集成后,通过消息队列Kafka版触发器(以下简称Kafka触发器)能够触发关联函数执行,通过函数可以对发布到消息队列Kafka版的消息进行自定义处理。本文介绍如何在函数计算控制台创建Kafka触发器、配置入口参数以及编写代码并测试代码。
功能简介
您在函数计算的控制台提交触发器创建请求之后,函数计算会根据触发器的配置信息,自动在事件总线EventBridge侧创建事件流资源。
创建完成后,您可以在函数计算控制台查看触发器信息,同时也可以在事件总线EventBridge控制台查看自动创建的资源信息。当源消息队列Kafka版中有消息入队时,将会触发函数计算执行,触发时会根据您的攒批配置将一个或多个消息事件以批的形式推送到函数中进行处理。
注意事项
- 作为触发源的消息队列Kafka版实例必须和函数计算的函数在相同的地域。
- 创建的事件流数量超过上限后,将无法再创建Kafka触发器。
在单个阿里云账号单个地域维度下,创建触发器涉及的资源数量的限制如下所示。
限制项 | 资源上限 |
---|---|
事件流数量 | 30 |
前提条件
- 事件总线EventBridge
- 函数计算
- 消息队列Kafka版
步骤一:创建Kafka触发器
步骤二:配置函数入口参数
消息队列Kafka版事件源会以event
的形式作为输入参数传递给函数,您可以手动将event
传给函数模拟触发事件。
步骤三:编写函数代码并测试
触发器创建完成后,您可以开始编写并测试函数代码,以验证代码的正确性。在实际操作过程中,当消息队列Kafka版事件发生时,触发器会自动触发函数的执行。
更多信息
除了函数计算控制台,您还可通过以下方式配置触发器:
- 通过Serverless Devs工具配置触发器。更多操作,请参见Serverless Devs。
- 通过SDK配置触发器。更多操作,请参见SDK列表。
如需对创建的触发器进行修改或删除,具体操作,请参见触发器管理。