如何通过Elasticsearch Bulk API仅获取失败文档？（PHP SDK）

刚好之前用PHP SDK处理Bulk请求时也遇到过这个问题，给你两个高效的解决方案，不用再挨个遍历所有请求项：

1. 利用PHP SDK内置的BulkResponse方法（推荐） #

官方的php-elasticsearch SDK提供了专门的方法来直接获取失败项和统计数，完全不用自己遍历全部请求：

// 发送批量请求
$bulkParams = [
    'body' => [
        // 你的index/update请求数组
    ]
];
$bulkResponse = $client->bulk($bulkParams);

// 快速获取成功/失败的文档数量
$successCount = $bulkResponse->getSuccessfulCount();
$failedCount = $bulkResponse->getFailedCount();

echo "本次批量请求：成功{$successCount}个，失败{$failedCount}个\n";

// 直接获取所有失败的请求详情
$failedItems = $bulkResponse->getFailedItems();
foreach ($failedItems as $item) {
    // 提取请求类型（index/update）、文档ID和错误信息
    $actionType = key($item);
    $documentId = $item[$actionType]['_id'];
    $errorDetail = $item[$actionType]['error'];
    
    echo "文档ID {$documentId} 的 {$actionType} 请求失败：{$errorDetail['type']} - {$errorDetail['reason']}\n";
}

这个方法最省心，SDK已经帮你做好了过滤和统计，性能和可读性都拉满。

2. 手动过滤响应数据（兼容旧版本SDK） #

如果你的SDK版本比较老，没有上面提到的便捷方法，可以直接处理响应的原始数组，用array_filter快速筛选失败项：

$bulkResponse = $client->bulk($bulkParams);
$rawResponse = $bulkResponse->asArray();

// 过滤出所有失败的请求项
$failedItems = array_filter($rawResponse['items'], function($item) {
    $action = key($item);
    // 判断依据：存在error字段，或者状态码>=400
    return isset($item[$action]['error']) || $item[$action]['status'] >= 400;
});

// 计算成功/失败数量
$totalCount = count($rawResponse['items']);
$failedCount = count($failedItems);
$successCount = $totalCount - $failedCount;

// 遍历失败项处理逻辑和上面一致
foreach ($failedItems as $item) {
    // 处理失败详情...
}

这样也能避免遍历全部请求，只处理有问题的项，效率提升明显。

内容的提问来源于stack exchange，提问作者Ashish Tiwari