如何在OpenSearch Ingestion Pipeline中触发并模拟DLQ行为？

AI 小北

2026-6-13

模拟AWS OpenSearch Ingestion Pipeline的DLQ行为的简便方法

插入不符合OpenSearch映射的无效数据
直接往DynamoDB写入一条与目标OpenSearch索引映射完全不匹配的数据，比如索引要求email字段为字符串类型，你写入一个数字或嵌套对象。管道尝试索引时会失败，达到重试次数上限后，这条消息就会被转发到DLQ。
临时修改OpenSearch集群端点为无效值
在管道配置里，将OpenSearch的输出端点改成一个不存在的地址（比如https://invalid-domain.us-east-1.es.amazonaws.com）。这样管道所有索引请求都会失败，很快就会将消息路由到DLQ。测试完成后记得改回正确端点。
使用fail处理器主动抛出异常
在管道的处理器阶段临时添加一个fail处理器，指定触发条件（比如匹配某个特定字段值），当消息满足条件时直接抛出异常，跳过重试流程进入DLQ。示例配置片段：
```
processors:
  - fail:
      if: "/id == 'test-dlq'"
      message: "Triggering DLQ for test purposes"
```
之后写入一条id为test-dlq的DDB记录，就能触发DLQ。测试完成后移除该处理器即可。
调整重试策略为最小次数
临时修改管道的重试配置，把max_retries设为0，关闭退避策略。这样只要第一次索引失败，消息就会直接进入DLQ。比如在OpenSearch输出部分添加：
```
sinks:
  - opensearch:
      ...
      retry:
        max_retries: 0
```
配合前面的无效数据或错误端点，就能快速触发DLQ行为。