Elasticsearch PHP客户端Delete by Query存在数据却未删除问题

我使用Elasticsearch的PHP客户端执行Delete by Query操作，posts索引存在父子文档关系。尝试删除子文档时，查询返回成功响应，但记录并未被删除，这个问题是偶发的，多数情况下查询能正常工作。

字段映射类型 #

"post_id" : {
     "type": "integer"
 }

查询代码 #

$query = [
            'index' => 'posts',
            'body' => [
                'query' => [
                    'bool' => [
                        'should' => [
                            [
                                "bool" => [
                                    "must" => [
                                        ['term' => ['type' => 'box_post']],
                                        ['term' => ['post_id' => (int) $post_id]]
                                    ]
                                ]
                            ],
                            [
                                "bool" => [
                                    "must" => [
                                        ['term' => ['type' => 'post_box']],
                                        ['term' => ['post_id' => (int) $post_id]]
                                    ]
                                ]
                            ]
                        ]
                    ]
                ]
            ]
        ];
 $this->client->deleteByQuery($query)

响应结果 #

Array
(
    [took] => 0
    [timed_out] => 
    [total] => 0
    [deleted] => 0
    [batches] => 0
    [version_conflicts] => 0
    [noops] => 0
    [retries] => Array
        (
            [bulk] => 0
            [search] => 0
        )

    [throttled_millis] => 0
    [requests_per_second] => -1
    [throttled_until_millis] => 0
    [failures] => Array
        (
        )
)

请问有没有办法确保当索引中存在对应记录时，查询必定能删除记录，而非返回无记录删除的成功响应？

解决思路与方案 #

1. 强制刷新索引后执行删除 #

父子文档操作后可能存在索引未实时刷新的延迟，导致Delete by Query查询不到刚写入的文档。可以在删除请求中添加refresh参数，确保索引状态最新：

$query = [
    'index' => 'posts',
    'refresh' => true,
    'body' => [
        // 原查询内容不变
    ]
];
$this->client->deleteByQuery($query);

也可以先手动刷新索引再执行删除：

$this->client->indices()->refresh(['index' => 'posts']);
$this->client->deleteByQuery($query);

2. 简化查询逻辑提升匹配稳定性 #

当前嵌套的should查询可以简化为terms查询type字段，减少嵌套可能带来的解析问题：

$query = [
    'index' => 'posts',
    'body' => [
        'query' => [
            'bool' => [
                'must' => [
                    ['terms' => ['type' => ['box_post', 'post_box']]],
                    ['term' => ['post_id' => (int) $post_id]]
                ]
            ]
        ]
    ]
];

3. 添加重试机制校验删除结果 #

检查删除响应的total和deleted字段，若存在应删除但未删除的情况，自动重试：

$maxRetries = 3;
$retryCount = 0;
do {
    $response = $this->client->deleteByQuery($query);
    if ($response['total'] > 0 && $response['deleted'] === $response['total']) {
        break;
    }
    $retryCount++;
    sleep(1);
} while ($retryCount < $maxRetries);

4. 确认路由一致性（若使用自定义路由） #

如果索引使用了自定义路由，Delete by Query必须指定相同的路由参数才能查询到对应文档：

$query = [
    'index' => 'posts',
    'routing' => $yourRoutingValue, // 匹配文档写入时的路由值
    'body' => [
        // 原查询内容
    ]
];

5. 排查父文档状态 #

父子文档中，父文档被删除后子文档会变为孤立文档，但默认不会自动删除。确保删除子文档的逻辑在父文档删除前执行，或业务上允许删除孤立子文档。

内容的提问来源于stack exchange，提问作者Rizwan Saleem