Elasticsearch查询调优几招

最近在做项目的时候遇到这个问题，查了不少资料总算搞明白了。把过程记下来，方便以后查阅，也希望能帮到有同样需求的朋友。

先搞清楚原理

Elasticsearch的基本概念其实不复杂。关键在于理解索引维护这个环节。看下面这段代码，逻辑就很清楚了：

-- 分区表创建
CREATE TABLE measurements_66 (
    id BIGSERIAL,
    sensor_id INTEGER NOT NULL,
    value DOUBLE PRECISION,
    recorded_at TIMESTAMP NOT NULL
) PARTITION BY RANGE (recorded_at);

CREATE TABLE measurements_66_q1 PARTITION OF measurements_66
    FOR VALUES FROM ('2024-01-01') TO ('2024-04-01');
CREATE TABLE measurements_66_q2 PARTITION OF measurements_66
    FOR VALUES FROM ('2024-04-01') TO ('2024-07-01');

CREATE INDEX idx_measurements_66_sensor ON measurements_66 (sensor_id, recorded_at);

EXPLAIN (ANALYZE, COSTS OFF)
SELECT * FROM measurements_66
WHERE recorded_at BETWEEN '2024-03-01' AND '2024-05-31';

实际怎么用

写代码的时候，Elasticsearch有几个常见写法。推荐用下面这种方式，代码更清晰，也更容易维护：

-- 存储过程与函数
CREATE OR REPLACE FUNCTION process_logs(p_id INTEGER)
RETURNS TABLE(id INTEGER, status TEXT, result TEXT) AS $$
DECLARE
    v_record RECORD;
BEGIN
    FOR v_record IN SELECT * FROM logs WHERE id = p_id LOOP
        IF v_record.status = 'pending' THEN
            UPDATE logs SET status = 'processed' WHERE id = v_record.id;
            RETURN QUERY SELECT v_record.id, 'processed'::TEXT, 'success'::TEXT;
        ELSE
            RETURN QUERY SELECT v_record.id, v_record.status::TEXT, 'skipped'::TEXT;
        END IF;
    END LOOP;
    RETURN;
END;
$$ LANGUAGE plpgsql;

SELECT * FROM process_logs(4);

进阶一点的用法

Elasticsearch在复杂场景下的用法和简单场景差别挺大。主要是索引结构选择这块需要额外处理，代码如下：

容易踩的坑

用Elasticsearch的时候有几个常见的错误写法。比如索引维护没有正确处理，或者索引结构选择的顺序搞反了。下面列出几个典型问题和修复方式。

写在最后

整体来看，Elasticsearch用起来不算复杂，关键是理解索引结构选择这个核心机制。建议先跑通基础示例，再逐步加功能。有问题可以看官方文档，社区也比较活跃。