# 死信队列
#### 概述
启用死信队列后EG会把处理失败的事件发送到配置的队列中，若不启用则处理失败的事件将被丢弃。
#### 操作步骤
1. 登录[事件网格控制台](https://console.huaweicloud.com/egs)。
2. 在左侧导航栏选择"事件订阅"，进入"事件订阅"页面。
3. 单击"创建事件订阅"。
4. 单击"事件目标"。
5. 在弹窗中选择"事件目标"。
6. 启用"死信队列"，并配置参数。 
   图1配置死信队列   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001670856109.png "点击放大")
   表1死信队列参数说明 
   | 参数名称  | 说明                                                                                            |
   |:---|:---|
   | 队列类型  | 选择队列类型。                                                                                       |
   | 实例    | 选择实例。                                                                                         |
   | 目标连接  | 选择目标连接。 **目前只能选择与队列类型匹配的目标连接。**                                   |
   | Topic | 选择Topic。 **如果事件目标与死信队列使用同一个Topic，EG将无法区分事件成功与失败，不推荐您配置同一个Topic。** |
      
   
   
7. 单击"确定"，完成死信配置。
 
#### 处理死信队列数据
当数据发送到死信队列后，您可以参考以下方法，来处理死信数据。
1. 登录[函数工作流控制台](https://console.huaweicloud.com/functiongraph)，在左侧的导航栏选择"函数 \> 函数列表"。
2. 单击右上方的"创建函数"，进入"创建函数"页面，具体创建步骤请参考[创建事件函数](https://support.huaweicloud.com/usermanual-functiongraph/functiongraph_01_1441.html)。
   
   图2函数列表   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001682236885.png "点击放大")
   
   
3. 选择创建的函数，单击进入函数详情页。
4. 选择"设置 \> 触发器"，单击"创建触发器"，弹出"创建触发器"对话框。 
   图3创建触发器   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001682236901.png "点击放大")
   
   
   
5. 设置以下信息。 
   - 触发器类型：选择"分布式消息服务（Kafka）"。
   
   - 实例：选择与死信队列相同的Kafka实例。
   
   - 主题：选择与死信队列相同的Topic。
   
   - 批处理大小：每次从Topic消费的消息数量，建议设置为10。
   
   - 用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。
   
   - 密码：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的密码。
   
   
   
   
6. 单击"确定"，完成kafka触发器的创建。
7. 单击"启用"，启用kafka触发器。 
   图4启用Kafka触发器   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001682443189.png "点击放大")
   
   
8. 编写死信数据的处理逻辑。 
   图5死信数据处理逻辑编写   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001682363461.png "点击放大")
   
   
9. 配置测试事件。 
   1. 单击"配置测试事件"，下拉框中单击"配置测试事件"。
   
   2. 选择"分布式消息Kafka版"，单击"创建"。
      图6配置测试事件   
      ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001684047509.png "点击放大") 
   
   3. 创建成功后在下拉框选择刚创建的测试事件。
   
   4. 单击"测试"，完成后可查看"执行结果"。
      图7执行结果   
      ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001635648390.png "点击放大")