死信队列

概述

启用死信队列后EG会把处理失败的事件发送到配置的队列中，若不启用则处理失败的事件将被丢弃。

操作步骤

1. 登录事件网格控制台。
2. 在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。
3. 单击“创建事件订阅”。
4. 单击“事件目标”。
5. 在弹窗中选择“事件目标”。
6. 启用“死信队列”，并配置参数。
   图1 配置死信队列
   

   表1 死信队列参数说明

   参数名称	说明
   队列类型	选择队列类型。
   实例	选择实例。
   目标连接	选择目标连接。 目前只能选择与队列类型匹配的目标连接。
   Topic	选择Topic。 如果事件目标与死信队列使用同一个Topic，EG将无法区分事件成功与失败，不推荐您配置同一个Topic。

7. 单击“确定”，完成死信配置。

处理死信队列数据

当数据发送到死信队列后，您可以参考以下方法，来处理死信数据。

1. 登录函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。
2. 单击右上方的“创建函数”，进入“创建函数”页面，具体创建步骤请参考创建事件函数。
   图2 函数列表
   

3. 选择创建的函数，单击进入函数详情页。
4. 选择“设置 > 触发器”，单击“创建触发器”，弹出“创建触发器”对话框。
   图3 创建触发器
   

5. 设置以下信息。
   • 触发器类型：选择“分布式消息服务（Kafka）”。
   • 实例：选择与死信队列相同的Kafka实例。
   • 主题：选择与死信队列相同的Topic。
   • 批处理大小：每次从Topic消费的消息数量，建议设置为10。
   • 用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。
   • 密码：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的密码。

6. 单击“确定”，完成kafka触发器的创建。
7. 单击“启用”，启用kafka触发器。
   图4 启用Kafka触发器
   

8. 编写死信数据的处理逻辑。
   图5 死信数据处理逻辑编写
   

9. 配置测试事件。
   1. 单击“配置测试事件”，下拉框中单击“配置测试事件”。
   2. 选择“分布式消息Kafka版”，单击“创建”。
      图6 配置测试事件
      
   3. 创建成功后在下拉框选择刚创建的测试事件。
   4. 单击“测试”，完成后可查看“执行结果”。
      图7 执行结果