本文介绍如何应用事件总线EventBridge的事件流功能实现消息路由至函数计算。

前提条件

• 开通事件总线EventBridge并授权。

• 开通函数计算并创建对应函数。

• 开通分布式消息服务Kafka并创建最少两个主题。

背景信息

事件流作为更轻量、实时端到端的流式事件通道，提供轻量级的流式数据的过滤和转换的能力，在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务Kafka生产的消息可以通过事件流这个通道被路由到目标端的函数计算，并触发函数。

步骤一：创建事件流

1. 登录事件总线EventBridge控制台。

2. 在左侧导航栏，单击事件流。

3. 在事件流页面，单击创建事件流。

4. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击保存。

   a.在Source（源）配置向导，选择数据提供方为分布式消息服务Kafka ，设置以下参数，然后单击下一步。

   参数	说明	示例
   Kafka实例	选择Kafka实例。	instance-xxx
   Kafka Topic	选择Kafka topic。	topic-xxx
   Group	选择消费组。	快速创建
   消费位点	选择消费位点。	最新位点

   b.在Filtering（过滤）配置向导，设置事件过滤规则，单击下一步。

   c.在Sink（目标）配置向导，选择服务类型为函数计算，配置以下参数，单击保存。

   参数	说明	示例
   函数	选择函数。	fun-xxx
   函数版本或别名	选择函数版本或别名。	版本/LATEST
   执行方式	选择执行函数的方式：同步或异步。	同步
   事件	选择调用到函数的事件内容，更多内容请参考事件内容转换。	完整事件

5. 创建事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

步骤二：测试验证

1. 登录分布式消息服务Kafka控制台。

2. 在左侧导航栏，单击实例列表，选择事件流的源实例。

3. 在主题管理页面，选择源的目标主题，操作列点击更多，然后点击生产消息。

4. 在生产消息对话框输入想要发送的消息，然后点击发送消息。

5. 发送消息后，登录函数计算管理控制台。

6. 在函数页面，单击目标函数名称。 

7. 在目标函数详情页面，单击监控页签，查看函数是否被触发以及调用时延，如图1所示。

   

   图1 在函数计算管理控制台中查看函数监控指标